@InterfaceAudience.Private public class ReversedMobStoreScanner extends StoreScanner
Modifier and Type | Field and Description |
---|---|
protected HMobStore |
mobStore |
cacheBlocks, cellsPerHeartbeatCheck, closing, columns, countPerRow, DEFAULT_HBASE_CELLS_SCANNED_PER_HEARTBEAT_CHECK, executor, explicitColumnQuery, HBASE_CELLS_SCANNED_PER_HEARTBEAT_CHECK, heap, isGet, isParallelSeekEnabled, lastTop, lazySeekEnabledGlobally, lock, matcher, maxRowSize, minVersions, now, oldestUnexpiredTS, readPt, scan, store, storeLimit, storeOffset, STORESCANNER_PARALLEL_SEEK_ENABLE, useRowColBloom
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,
KeyValue.KVComparator comparator)
Check whether scan as expected order
|
boolean |
next(java.util.List<Cell> outResult,
ScannerContext ctx)
Firstly reads the cells from the HBase.
|
boolean |
reseek(Cell kv)
Reseek the scanner at or after the specified KeyValue.
|
protected void |
resetKVHeap(java.util.List<? extends KeyValueScanner> scanners,
KeyValue.KVComparator 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
|
checkReseek, close, getEstimatedNumberOfKvsScanned, getNextIndexedKey, getScannersNoCompaction, getSequenceID, next, next, peek, resetScannerStack, selectScannersFrom, updateReaders
seekToLastRow
doRealSeek, enforceSeek, isFileScanner, realSeekDone, requestSeek, shouldUseScanner
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, enforceSeek, getNextIndexedKey, getSequenceID, isFileScanner, next, peek, realSeekDone, requestSeek, seekToLastRow, shouldUseScanner
protected final HMobStore mobStore
public boolean next(java.util.List<Cell> outResult, ScannerContext ctx) throws java.io.IOException
next
in interface InternalScanner
next
in class StoreScanner
outResult
- return output arrayjava.io.IOException
- eprotected void resetKVHeap(java.util.List<? extends KeyValueScanner> scanners, KeyValue.KVComparator 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, KeyValue.KVComparator 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