Package org.apache.hadoop.hbase.regionserver

Class TestStoreScannerClosure.ExtendedStoreScanner

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.TestStoreScannerClosure.ExtendedStoreScanner

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:

TestStoreScannerClosure

private static class TestStoreScannerClosure.ExtendedStoreScanner
extends org.apache.hadoop.hbase.regionserver.StoreScanner

Field Summary

Fields

Modifier and Type	Field	Description
private CountDownLatch	latch

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
ExtendedStoreScanner(org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.ScanInfo scanInfo, org.apache.hadoop.hbase.client.Scan scan, NavigableSet<byte[]> columns, long readPt)

Method Summary

Modifier and Type	Method	Description
void	close(boolean await, boolean dummy)
void	updateReaders(boolean await, List<org.apache.hadoop.hbase.regionserver.HStoreFile> sfs, List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> memStoreScanners)

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

checkFlushed, checkScanOrder, close, enableLazySeekGlobally, getAllScannersForTesting, getEstimatedNumberOfKvsScanned, getNextIndexedKey, getReadPoint, hasSwitchedToStreamRead, hasUpdatedReaders, instrument, isScanUsePread, newKVHeap, next, next, peek, reopenAfterFlush, reseek, resetHasSwitchedToStreamRead, resetHasUpdatedReaders, resetKVHeap, seek, seekAsDirection, seekScanners, 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

latch

private CountDownLatch latch

Constructor Details

ExtendedStoreScanner

public ExtendedStoreScanner(org.apache.hadoop.hbase.regionserver.HStore store,
 org.apache.hadoop.hbase.regionserver.ScanInfo scanInfo,
 org.apache.hadoop.hbase.client.Scan scan,
 NavigableSet<byte[]> columns,
 long readPt)
                     throws IOException

Throws:

IOException

Method Details

updateReaders

public void updateReaders(boolean await,
 List<org.apache.hadoop.hbase.regionserver.HStoreFile> sfs,
 List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> memStoreScanners)
                   throws IOException

Throws:

IOException

close

public void close(boolean await,
 boolean dummy)