@InterfaceAudience.Private public class ReversedMobStoreScanner extends ReversedStoreScanner
Modifier and Type | Field and Description |
---|---|
private boolean |
cacheMobBlocks |
private static org.slf4j.Logger |
LOG |
private HMobStore |
mobStore |
private boolean |
rawMobScan |
private boolean |
readEmptyValueOnMobCellMiss |
private List<MobCell> |
referencedMobCells |
currentScanners, DEFAULT_HBASE_CELLS_SCANNED_PER_HEARTBEAT_CHECK, HBASE_CELLS_SCANNED_PER_HEARTBEAT_CHECK, heap, LAZY_SEEK_ENABLED_BY_DEFAULT, memstoreOnlyReads, mixedReads, readPt, store, STORESCANNER_PARALLEL_SEEK_ENABLE, STORESCANNER_PREAD_MAX_BYTES
NO_NEXT_INDEXED_KEY
Constructor and Description |
---|
ReversedMobStoreScanner(HStore store,
ScanInfo scanInfo,
Scan scan,
NavigableSet<byte[]> columns,
long readPt) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the KeyValue scanner.
|
private void |
freeAllReferencedMobCells() |
boolean |
next(List<Cell> outResult,
ScannerContext ctx)
Firstly reads the cells from the HBase.
|
void |
shipped()
Called after a batch of rows scanned and set to be returned to client.
|
backwardSeek, checkScanOrder, newKVHeap, reseek, seek, seekAsDirection, seekScanners, seekToNextRow, seekToPreviousRow
checkFlushed, enableLazySeekGlobally, getAllScannersForTesting, getEstimatedNumberOfKvsScanned, getNextIndexedKey, getReadPoint, isScanUsePread, next, peek, reopenAfterFlush, resetKVHeap, selectScannersFrom, trySkipToNextColumn, trySkipToNextRow, trySwitchToStreamRead, updateReaders
seekToLastRow
doRealSeek, enforceSeek, getFilePath, isFileScanner, realSeekDone, requestSeek, shouldUseScanner
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
enforceSeek, getFilePath, getNextIndexedKey, getScannerOrder, isFileScanner, next, peek, realSeekDone, requestSeek, seekToLastRow, shouldUseScanner
next
private static final org.slf4j.Logger LOG
private boolean cacheMobBlocks
private boolean rawMobScan
private boolean readEmptyValueOnMobCellMiss
private final List<MobCell> referencedMobCells
ReversedMobStoreScanner(HStore store, ScanInfo scanInfo, Scan scan, NavigableSet<byte[]> columns, long readPt) throws IOException
IOException
public boolean next(List<Cell> outResult, ScannerContext ctx) throws IOException
next
in interface InternalScanner
next
in class StoreScanner
outResult
- return output array n * @return true if more rows exist after this one, false if
scanner is doneIOException
- eprivate void freeAllReferencedMobCells() throws IOException
IOException
public void shipped() throws IOException
Shipper
shipped
in interface Shipper
shipped
in class StoreScanner
IOException
public void close()
KeyValueScanner
close
in interface Closeable
close
in interface AutoCloseable
close
in interface InternalScanner
close
in interface KeyValueScanner
close
in class StoreScanner
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.