@InterfaceAudience.Private public class MobStoreScanner extends StoreScanner
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
Constructor and Description |
---|
MobStoreScanner(Store store,
ScanInfo scanInfo,
Scan scan,
java.util.NavigableSet<byte[]> columns,
long readPt) |
Modifier and Type | Method and Description |
---|---|
boolean |
next(java.util.List<Cell> outResult,
ScannerContext ctx)
Firstly reads the cells from the HBase.
|
checkReseek, checkScanOrder, close, getEstimatedNumberOfKvsScanned, getNextIndexedKey, getScannersNoCompaction, getSequenceID, next, next, peek, reseek, resetKVHeap, resetScannerStack, seek, seekAsDirection, seekScanners, seekToNextRow, selectScannersFrom, updateReaders
backwardSeek, seekToLastRow, seekToPreviousRow
doRealSeek, enforceSeek, isFileScanner, realSeekDone, requestSeek, shouldUseScanner
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
backwardSeek, enforceSeek, isFileScanner, realSeekDone, requestSeek, seekToLastRow, seekToPreviousRow, shouldUseScanner
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
- e