@InterfaceAudience.Private 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,
long readPointToUse,
long oldestUnexpiredTS,
long now) |
| Modifier and Type | Method and Description |
|---|---|
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, instantiateDeleteTracker, match, preCheck, setToNewRowprotected final long maxReadPointToTrackVersions
protected final DeleteTracker deletes
protected final KeepDeletedCells keepDeletedCells
protected CompactionScanQueryMatcher(ScanInfo scanInfo, DeleteTracker deletes, long readPointToUse, long oldestUnexpiredTS, long now)
public boolean hasNullColumnInQuery()
hasNullColumnInQuery in class ScanQueryMatcherpublic boolean isUserScan()
isUserScan in class ScanQueryMatcherpublic boolean moreRowsMayExistAfter(Cell cell)
moreRowsMayExistAfter in class ScanQueryMatcherstopRow or we are scanning on row only because this Scan is for a Get,
etc.public Filter getFilter()
getFilter in class ScanQueryMatcherpublic Cell getNextKeyHint(Cell cell) throws IOException
ScanQueryMatcherFilter.getNextCellHint(Cell). If no filter, return null.getNextKeyHint in class ScanQueryMatcherIOExceptionprotected void reset()
reset in class ScanQueryMatcherprotected 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 IOException
IOExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.