public abstract class CompactionScanQueryMatcher extends ScanQueryMatcher
ScanQueryMatcher.MatchCode
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
|
columns, currentRow, now, oldestUnexpiredTS, rowComparator, startKey
Modifier | Constructor and Description |
---|---|
protected |
CompactionScanQueryMatcher(ScanInfo scanInfo,
DeleteTracker deletes,
ColumnTracker columnTracker,
long readPointToUse,
long oldestUnexpiredTS,
long now) |
Modifier and Type | Method and Description |
---|---|
void |
beforeShipped() |
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) |
checkDeleted, clearCurrentRow, compareKeyForNextColumn, compareKeyForNextRow, createStartKeyFromRow, currentRow, getKeyForNextColumn, getStartKey, getTrackers, match, preCheck, setToNewRow
protected final long maxReadPointToTrackVersions
protected final DeleteTracker deletes
protected final KeepDeletedCells keepDeletedCells
protected CompactionScanQueryMatcher(ScanInfo scanInfo, DeleteTracker deletes, ColumnTracker columnTracker, long readPointToUse, long oldestUnexpiredTS, long now)
public void beforeShipped() throws java.io.IOException
beforeShipped
in class ScanQueryMatcher
java.io.IOException
public boolean hasNullColumnInQuery()
hasNullColumnInQuery
in class ScanQueryMatcher
public boolean isUserScan()
isUserScan
in class ScanQueryMatcher
public boolean moreRowsMayExistAfter(Cell cell)
moreRowsMayExistAfter
in class ScanQueryMatcher
stopRow
or we are scanning on row only because this Scan is for a Get,
etc.public Filter getFilter()
getFilter
in class ScanQueryMatcher
public Cell getNextKeyHint(Cell cell) throws java.io.IOException
ScanQueryMatcher
Filter#getNextCellHint(Cell)
. If no filter, return null
.getNextKeyHint
in class ScanQueryMatcher
java.io.IOException
protected void reset()
reset
in class ScanQueryMatcher
protected final void trackDelete(Cell cell)
public static CompactionScanQueryMatcher create(ScanInfo scanInfo, ScanType scanType, long readPointToUse, long earliestPutTs, long oldestUnexpiredTS, long now, byte[] dropDeletesFromRow, byte[] dropDeletesToRow, RegionCoprocessorHost regionCoprocessorHost) throws java.io.IOException
java.io.IOException