org.apache.hadoop.hbase.regionserver.querymatcher

Class CompactionScanQueryMatcher

java.lang.Object

org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher

org.apache.hadoop.hbase.regionserver.querymatcher.CompactionScanQueryMatcher

All Implemented Interfaces:

ShipperListener

Direct Known Subclasses:

DropDeletesCompactionScanQueryMatcher, MinorCompactionScanQueryMatcher

@InterfaceAudience.Private
public abstract class CompactionScanQueryMatcher
extends ScanQueryMatcher

Query matcher for compaction.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher

ScanQueryMatcher.MatchCode

Field Summary

Fields

Modifier and Type	Field and Description
protected DeleteTracker	deletes Keeps track of deletes
protected KeepDeletedCells	keepDeletedCells whether to return deleted rows
protected long	maxReadPointToTrackVersions readPoint over which the KVs are unconditionally included

Fields inherited from class org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher

columns, currentRow, now, oldestUnexpiredTS, rowComparator, startKey

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	CompactionScanQueryMatcher(ScanInfo scanInfo, DeleteTracker deletes, ColumnTracker columnTracker, long readPointToUse, long oldestUnexpiredTS, long now)

Method Summary

Modifier and Type	Method and Description
void	beforeShipped() The action that needs to be performed before Shipper.shipped() is performed
static CompactionScanQueryMatcher	create(ScanInfo scanInfo, ScanType scanType, long readPointToUse, long earliestPutTs, long oldestUnexpiredTS, long now, byte[] dropDeletesFromRow, byte[] dropDeletesToRow, RegionCoprocessorHost regionCoprocessorHost)
Filter	getFilter()
Cell	getNextKeyHint(Cell cell) Delegate to Filter.getNextCellHint(Cell).
boolean	hasNullColumnInQuery()
boolean	isUserScan()
boolean	moreRowsMayExistAfter(Cell cell)
protected void	reset()
protected void	trackDelete(Cell cell)

Methods inherited from class org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher

checkColumn, checkDeleted, clearCurrentRow, compareKeyForNextColumn, compareKeyForNextRow, createStartKeyFromRow, currentRow, getKeyForNextColumn, getStartKey, getTrackers, match, preCheck, setToNewRow

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

maxReadPointToTrackVersions

protected final long maxReadPointToTrackVersions

readPoint over which the KVs are unconditionally included

deletes

protected final DeleteTracker deletes

Keeps track of deletes

keepDeletedCells

protected final KeepDeletedCells keepDeletedCells

whether to return deleted rows

Constructor Detail

CompactionScanQueryMatcher

protected CompactionScanQueryMatcher(ScanInfo scanInfo,
                                     DeleteTracker deletes,
                                     ColumnTracker columnTracker,
                                     long readPointToUse,
                                     long oldestUnexpiredTS,
                                     long now)

Method Detail

beforeShipped

public void beforeShipped()
                   throws IOException

Description copied from interface: ShipperListener

The action that needs to be performed before Shipper.shipped() is performed

Specified by:

beforeShipped in interface ShipperListener

Overrides:

beforeShipped in class ScanQueryMatcher

Throws:

IOException

hasNullColumnInQuery

public boolean hasNullColumnInQuery()

Specified by:

hasNullColumnInQuery in class ScanQueryMatcher

Returns:

whether there is an null column in the query

isUserScan

public boolean isUserScan()

Specified by:

isUserScan in class ScanQueryMatcher

moreRowsMayExistAfter

public boolean moreRowsMayExistAfter(Cell cell)

Specified by:

moreRowsMayExistAfter in class ScanQueryMatcher

Returns:

Returns false if we know there are no more rows to be scanned (We've reached the stopRow or we are scanning on row only because this Scan is for a Get, etc.

getFilter

public Filter getFilter()

Specified by:

getFilter in class ScanQueryMatcher

Returns:

the Filter

getNextKeyHint

public Cell getNextKeyHint(Cell cell)
                    throws IOException

Description copied from class: ScanQueryMatcher

Delegate to Filter.getNextCellHint(Cell). If no filter, return null.

Specified by:

getNextKeyHint in class ScanQueryMatcher

Throws:

IOException

reset

protected void reset()

Specified by:

reset in class ScanQueryMatcher

trackDelete

protected final void trackDelete(Cell cell)

create

public static CompactionScanQueryMatcher create(ScanInfo scanInfo,
                                                ScanType scanType,
                                                long readPointToUse,
                                                long earliestPutTs,
                                                long oldestUnexpiredTS,
                                                long now,
                                                byte[] dropDeletesFromRow,
                                                byte[] dropDeletesToRow,
                                                RegionCoprocessorHost regionCoprocessorHost)
                                         throws IOException

Throws:

IOException