Package org.apache.hadoop.hbase.regionserver

Class TestScanner.RecordingStoreScanner

java.lang.Object

org.apache.hadoop.hbase.regionserver.NonLazyKeyValueScanner

org.apache.hadoop.hbase.regionserver.NonReversedNonLazyKeyValueScanner

org.apache.hadoop.hbase.regionserver.StoreScanner

org.apache.hadoop.hbase.regionserver.TestScanner.RecordingStoreScanner

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.hbase.regionserver.ChangedReadersObserver, org.apache.hadoop.hbase.regionserver.InternalScanner, org.apache.hadoop.hbase.regionserver.KeyValueScanner, org.apache.hadoop.hbase.regionserver.Shipper

Enclosing class:

TestScanner

private static final class TestScanner.RecordingStoreScanner
extends org.apache.hadoop.hbase.regionserver.StoreScanner

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	initialSeekWasLazy

Fields inherited from class org.apache.hadoop.hbase.regionserver.StoreScanner

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

Fields inherited from interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

NO_NEXT_INDEXED_KEY

Constructor Summary

Constructors

Constructor	Description
RecordingStoreScanner(org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.client.Scan scan, NavigableSet<byte[]> columns)

Method Summary

Modifier and Type	Method	Description
protected void	seekScanners(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, org.apache.hadoop.hbase.ExtendedCell seekKey, boolean isLazy, boolean isParallelSeek)

Methods inherited from class org.apache.hadoop.hbase.regionserver.StoreScanner

checkFlushed, checkScanOrder, close, enableLazySeekGlobally, getAllScannersForTesting, getEstimatedNumberOfKvsScanned, getFilesRead, getNextIndexedKey, getReadPoint, hasSwitchedToStreamRead, hasUpdatedReaders, instrument, isScanUsePread, newKVHeap, next, next, peek, reopenAfterFlush, reseek, resetHasSwitchedToStreamRead, resetHasUpdatedReaders, resetKVHeap, seek, seekAsDirection, seekToNextRow, selectScannersFrom, shipped, trySkipToNextColumn, trySkipToNextRow, trySwitchToStreamRead, updateReaders

Methods inherited from class org.apache.hadoop.hbase.regionserver.NonReversedNonLazyKeyValueScanner

backwardSeek, seekToLastRow, seekToPreviousRow

Methods inherited from class org.apache.hadoop.hbase.regionserver.NonLazyKeyValueScanner

doRealSeek, enforceSeek, getFilePath, isFileScanner, realSeekDone, recordBlockSize, requestSeek, shouldUseScanner

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.regionserver.InternalScanner

next

Methods inherited from interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

backwardSeek, enforceSeek, getFilePath, getScannerOrder, isFileScanner, realSeekDone, recordBlockSize, requestSeek, seekToLastRow, seekToPreviousRow, shouldUseScanner

Field Details

initialSeekWasLazy

private boolean initialSeekWasLazy

Constructor Details

RecordingStoreScanner

RecordingStoreScanner(org.apache.hadoop.hbase.regionserver.HStore store,
 org.apache.hadoop.hbase.client.Scan scan,
 NavigableSet<byte[]> columns)
               throws IOException

Throws:

IOException

Method Details

seekScanners

protected void seekScanners(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners,
 org.apache.hadoop.hbase.ExtendedCell seekKey,
 boolean isLazy,
 boolean isParallelSeek)
                     throws IOException

Overrides:

seekScanners in class org.apache.hadoop.hbase.regionserver.StoreScanner

Throws:

IOException