public class ReversedStoreScanner extends StoreScanner implements KeyValueScanner
DEFAULT_HBASE_CELLS_SCANNED_PER_HEARTBEAT_CHECK, HBASE_CELLS_SCANNED_PER_HEARTBEAT_CHECK, heap, readPt, store, STORESCANNER_PARALLEL_SEEK_ENABLE, STORESCANNER_PREAD_MAX_BYTES
NO_NEXT_INDEXED_KEY
Constructor and Description |
---|
ReversedStoreScanner(HStore store,
ScanInfo scanInfo,
Scan scan,
java.util.NavigableSet<byte[]> columns,
long readPt)
Opens a scanner across memstore, snapshot, and all StoreFiles.
|
ReversedStoreScanner(Scan scan,
ScanInfo scanInfo,
java.util.NavigableSet<byte[]> columns,
java.util.List<? extends KeyValueScanner> scanners)
Constructor for testing.
|
Modifier and Type | Method and Description |
---|---|
boolean |
backwardSeek(Cell key)
Seek the scanner at or before the row of specified Cell, it firstly
tries to seek the scanner at or after the specified Cell, return if
peek KeyValue of scanner has the same row with specified Cell,
otherwise seek the scanner at the first Cell of the row which is the
previous row of specified KeyValue
|
protected void |
checkScanOrder(Cell prevKV,
Cell kv,
CellComparator comparator)
Check whether scan as expected order
|
boolean |
reseek(Cell kv)
Reseek the scanner at or after the specified KeyValue.
|
protected void |
resetKVHeap(java.util.List<? extends KeyValueScanner> scanners,
CellComparator comparator) |
boolean |
seek(Cell key)
Seek the scanner at or after the specified KeyValue.
|
protected boolean |
seekAsDirection(Cell kv)
Do a backwardSeek in a reversed StoreScanner(scan backward)
|
protected void |
seekScanners(java.util.List<? extends KeyValueScanner> scanners,
Cell seekKey,
boolean isLazy,
boolean isParallelSeek)
Seek the specified scanners with the given key
|
protected boolean |
seekToNextRow(Cell kv) |
boolean |
seekToPreviousRow(Cell key)
Seek the scanner at the first Cell of the row which is the previous row
of specified key
|
checkFlushed, close, getEstimatedNumberOfKvsScanned, getNextIndexedKey, getReadPoint, getScannerOrder, next, next, peek, reopenAfterFlush, selectScannersFrom, shipped, trySkipToNextColumn, trySkipToNextRow, updateReaders
seekToLastRow
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, enforceSeek, getFilePath, getNextIndexedKey, getScannerOrder, isFileScanner, next, peek, realSeekDone, requestSeek, seekToLastRow, shouldUseScanner
next
public ReversedStoreScanner(HStore store, ScanInfo scanInfo, Scan scan, java.util.NavigableSet<byte[]> columns, long readPt) throws java.io.IOException
store
- who we scanscanInfo
- scan
- the speccolumns
- which columns we are scanningjava.io.IOException
public ReversedStoreScanner(Scan scan, ScanInfo scanInfo, java.util.NavigableSet<byte[]> columns, java.util.List<? extends KeyValueScanner> scanners) throws java.io.IOException
java.io.IOException
protected void resetKVHeap(java.util.List<? extends KeyValueScanner> scanners, CellComparator comparator) throws java.io.IOException
resetKVHeap
in class StoreScanner
java.io.IOException
protected void seekScanners(java.util.List<? extends KeyValueScanner> scanners, Cell seekKey, boolean isLazy, boolean isParallelSeek) throws java.io.IOException
StoreScanner
seekScanners
in class StoreScanner
isLazy
- true if using lazy seekisParallelSeek
- true if using parallel seekjava.io.IOException
protected boolean seekToNextRow(Cell kv) throws java.io.IOException
seekToNextRow
in class StoreScanner
java.io.IOException
protected boolean seekAsDirection(Cell kv) throws java.io.IOException
seekAsDirection
in class StoreScanner
java.io.IOException
protected void checkScanOrder(Cell prevKV, Cell kv, CellComparator comparator) throws java.io.IOException
StoreScanner
checkScanOrder
in class StoreScanner
java.io.IOException
public boolean reseek(Cell kv) throws java.io.IOException
KeyValueScanner
reseek
in interface KeyValueScanner
reseek
in class StoreScanner
kv
- seek value (should be non-null)java.io.IOException
public boolean seek(Cell key) throws java.io.IOException
KeyValueScanner
seek
in interface KeyValueScanner
seek
in class StoreScanner
key
- seek valuejava.io.IOException
public boolean seekToPreviousRow(Cell key) throws java.io.IOException
KeyValueScanner
seekToPreviousRow
in interface KeyValueScanner
seekToPreviousRow
in class NonReversedNonLazyKeyValueScanner
key
- seek valuejava.io.IOException
public boolean backwardSeek(Cell key) throws java.io.IOException
KeyValueScanner
backwardSeek
in interface KeyValueScanner
backwardSeek
in class NonReversedNonLazyKeyValueScanner
key
- seek KeyValuejava.io.IOException