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 and 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 and 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 and 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, isScanUsePread, newKVHeap, next, next, peek, reopenAfterFlush, reseek, 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, 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.KeyValueScanner

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

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

next

Field Detail

latch

private CountDownLatch latch

Constructor Detail

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 Detail

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)