public abstract class NormalUserScanQueryMatcher extends UserScanQueryMatcher
ScanQueryMatcher.MatchCode
Modifier and Type | Field and Description |
---|---|
protected boolean |
seePastDeleteMarkers
whether time range queries can see rows "behind" a delete
|
filter, hasNullColumn, stopRow, tr
columns, currentRow, now, oldestUnexpiredTS, rowComparator, startKey
Modifier | Constructor and Description |
---|---|
protected |
NormalUserScanQueryMatcher(Scan scan,
ScanInfo scanInfo,
ColumnTracker columns,
boolean hasNullColumn,
DeleteTracker deletes,
long oldestUnexpiredTS,
long now) |
Modifier and Type | Method and Description |
---|---|
void |
beforeShipped() |
static NormalUserScanQueryMatcher |
create(Scan scan,
ScanInfo scanInfo,
ColumnTracker columns,
DeleteTracker deletes,
boolean hasNullColumn,
long oldestUnexpiredTS,
long now) |
protected boolean |
isGet() |
ScanQueryMatcher.MatchCode |
match(Cell cell)
Determines if the caller should do one of several things:
seek/skip to the next row (MatchCode.SEEK_NEXT_ROW)
seek/skip to the next column (MatchCode.SEEK_NEXT_COL)
include the current KeyValue (MatchCode.INCLUDE)
ignore the current KeyValue (MatchCode.SKIP)
got to the next row (MatchCode.DONE)
|
protected void |
reset() |
create, getFilter, getNextKeyHint, hasNullColumnInQuery, isUserScan, matchColumn, moreRowsMayExistAfter, moreRowsMayExistsAfter
checkDeleted, clearCurrentRow, compareKeyForNextColumn, compareKeyForNextRow, createStartKeyFromRow, currentRow, getKeyForNextColumn, getStartKey, getTrackers, preCheck, setToNewRow
protected final boolean seePastDeleteMarkers
protected NormalUserScanQueryMatcher(Scan scan, ScanInfo scanInfo, ColumnTracker columns, boolean hasNullColumn, DeleteTracker deletes, long oldestUnexpiredTS, long now)
public void beforeShipped() throws java.io.IOException
beforeShipped
in class UserScanQueryMatcher
java.io.IOException
public ScanQueryMatcher.MatchCode match(Cell cell) throws java.io.IOException
ScanQueryMatcher
match
in class ScanQueryMatcher
cell
- KeyValue to checkjava.io.IOException
- in case there is an internal consistency problem caused by a data
corruption.protected void reset()
reset
in class ScanQueryMatcher
protected boolean isGet()
isGet
in class UserScanQueryMatcher
public static NormalUserScanQueryMatcher create(Scan scan, ScanInfo scanInfo, ColumnTracker columns, DeleteTracker deletes, boolean hasNullColumn, long oldestUnexpiredTS, long now) throws java.io.IOException
java.io.IOException