Uses of Interface
org.apache.hadoop.hbase.regionserver.KeyValueScanner

Packages that use KeyValueScanner

Package	Description
org.apache.hadoop.hbase.regionserver
org.apache.hadoop.hbase.regionserver.handler
org.apache.hadoop.hbase.util

Uses of KeyValueScanner in org.apache.hadoop.hbase.regionserver

Classes in org.apache.hadoop.hbase.regionserver that implement KeyValueScanner

Modifier and Type	Class and Description
class	KeyValueHeap Implements a heap merge across any number of KeyValueScanners.
class	MobStoreScanner Scanner scans both the memstore and the MOB Store.
class	NonLazyKeyValueScanner A "non-lazy" scanner which always does a real seek operation.
class	NonReversedNonLazyKeyValueScanner A "non-reversed & non-lazy" scanner which does not support backward scanning and always does a real seek operation.
class	ReversedKeyValueHeap ReversedKeyValueHeap is used for supporting reversed scanning.
class	ReversedMobStoreScanner ReversedMobStoreScanner extends from ReversedStoreScanner, and is used to support reversed scanning in both the memstore and the MOB store.
class	ReversedStoreScanner ReversedStoreScanner extends from StoreScanner, and is used to support reversed scanning.
class	SegmentScanner A scanner of a single memstore segment.
class	SnapshotSegmentScanner A basic SegmentScanner used against an ImmutableScanner snapshot Used flushing where we do a single pass, no reverse scanning or inserts happening.
class	StoreFileScanner KeyValueScanner adaptor over the Reader.
class	StoreScanner Scanner scans both the memstore and the Store.

Fields in org.apache.hadoop.hbase.regionserver declared as KeyValueScanner

Modifier and Type	Field and Description
protected KeyValueScanner	KeyValueHeap.current The current sub-scanner, i.e.

Fields in org.apache.hadoop.hbase.regionserver with type parameters of type KeyValueScanner

Modifier and Type	Field and Description
(package private) List<KeyValueScanner>	StoreScanner.currentScanners
private List<KeyValueScanner>	StoreScanner.flushedstoreFileScanners
protected PriorityQueue<KeyValueScanner>	KeyValueHeap.heap
private List<KeyValueScanner>	StoreScanner.memStoreScannersAfterFlush
private List<KeyValueScanner>	MemStoreSnapshot.scanners
(package private) List<KeyValueScanner>	MemStoreMergerSegmentsIterator.scanners
protected List<KeyValueScanner>	KeyValueHeap.scannersForDelayedClose
private List<KeyValueScanner>	StoreScanner.scannersForDelayedClose

Methods in org.apache.hadoop.hbase.regionserver that return KeyValueScanner

Modifier and Type	Method and Description
protected KeyValueScanner	HMobStore.createScanner(Scan scan, ScanInfo scanInfo, NavigableSet<byte[]> targetCols, long readPt) Gets the MobStoreScanner or MobReversedStoreScanner.
protected KeyValueScanner	HStore.createScanner(Scan scan, ScanInfo scanInfo, NavigableSet<byte[]> targetCols, long readPt)
(package private) KeyValueScanner	KeyValueHeap.getCurrentForTesting()
protected KeyValueScanner	Segment.getScanner(long readPoint) Creates the scanner for the given read point
KeyValueScanner	CompositeImmutableSegment.getScanner(long readPoint) Creates the scanner for the given read point
KeyValueScanner	Segment.getScanner(long readPoint, long order) Creates the scanner for the given read point, and a specific order in a list
KeyValueScanner	CompositeImmutableSegment.getScanner(long readPoint, long order) Creates the scanner for the given read point, and a specific order in a list
KeyValueScanner	HStore.getScanner(Scan scan, NavigableSet<byte[]> targetCols, long readPt) Return a scanner for both the memstore and the HStore files.
protected KeyValueScanner	KeyValueHeap.pollRealKV() Fetches the top sub-scanner from the priority queue, ensuring that a real seek has been done on it.

Methods in org.apache.hadoop.hbase.regionserver that return types with arguments of type KeyValueScanner

Modifier and Type	Method and Description
protected List<KeyValueScanner>	CompactingMemStore.createList(int capacity)
(package private) List<KeyValueScanner>	StoreScanner.getAllScannersForTesting() Used in testing.
PriorityQueue<KeyValueScanner>	KeyValueHeap.getHeap()
List<KeyValueScanner>	MemStoreSnapshot.getScanners()
List<KeyValueScanner>	HStore.getScanners(boolean cacheBlocks, boolean isGet, boolean usePread, boolean isCompaction, ScanQueryMatcher matcher, byte[] startRow, byte[] stopRow, long readPt) Get all scanners with no filtering based on TTL (that happens further down the line).
List<KeyValueScanner>	HStore.getScanners(boolean cacheBlocks, boolean usePread, boolean isCompaction, ScanQueryMatcher matcher, byte[] startRow, boolean includeStartRow, byte[] stopRow, boolean includeStopRow, long readPt) Get all scanners with no filtering based on TTL (that happens further down the line).
List<KeyValueScanner>	HStore.getScanners(List<HStoreFile> files, boolean cacheBlocks, boolean isGet, boolean usePread, boolean isCompaction, ScanQueryMatcher matcher, byte[] startRow, byte[] stopRow, long readPt, boolean includeMemstoreScanner) Create scanners on the given files and if needed on the memstore with no filtering based on TTL (that happens further down the line).
List<KeyValueScanner>	HStore.getScanners(List<HStoreFile> files, boolean cacheBlocks, boolean usePread, boolean isCompaction, ScanQueryMatcher matcher, byte[] startRow, boolean includeStartRow, byte[] stopRow, boolean includeStopRow, long readPt, boolean includeMemstoreScanner) Create scanners on the given files and if needed on the memstore with no filtering based on TTL (that happens further down the line).
List<KeyValueScanner>	CompactingMemStore.getScanners(long readPt)
List<KeyValueScanner>	DefaultMemStore.getScanners(long readPt)
List<KeyValueScanner>	MemStore.getScanners(long readPt)
List<KeyValueScanner>	Segment.getScanners(long readPoint, long order)
List<KeyValueScanner>	CompositeImmutableSegment.getScanners(long readPoint, long order)
(package private) List<KeyValueScanner>	CompositeImmutableSegment.getSnapshotScanners()
(package private) List<KeyValueScanner>	ImmutableSegment.getSnapshotScanners()
List<KeyValueScanner>	HStore.recreateScanners(List<KeyValueScanner> currentFileScanners, boolean cacheBlocks, boolean usePread, boolean isCompaction, ScanQueryMatcher matcher, byte[] startRow, boolean includeStartRow, byte[] stopRow, boolean includeStopRow, long readPt, boolean includeMemstoreScanner) Recreates the scanners on the current list of active store file scanners
protected List<KeyValueScanner>	StoreScanner.selectScannersFrom(HStore store, List<? extends KeyValueScanner> allScanners) Filters the given list of scanners using Bloom filter, time range, and TTL.

Methods in org.apache.hadoop.hbase.regionserver with parameters of type KeyValueScanner

Modifier and Type	Method and Description
int	ReversedKeyValueHeap.ReversedKVScannerComparator.compare(KeyValueScanner left, KeyValueScanner right)
int	KeyValueHeap.KVScannerComparator.compare(KeyValueScanner left, KeyValueScanner right)
static boolean	NonLazyKeyValueScanner.doRealSeek(KeyValueScanner scanner, Cell kv, boolean forward)
private void	CellArrayImmutableSegment.reinitializeCellSet(int numOfCells, KeyValueScanner segmentScanner, CellSet oldCellSet, MemStoreCompactionStrategy.Action action)
private void	CellChunkImmutableSegment.reinitializeCellSet(int numOfCells, KeyValueScanner segmentScanner, CellSet oldCellSet, MemStoreCompactionStrategy.Action action)

Method parameters in org.apache.hadoop.hbase.regionserver with type arguments of type KeyValueScanner

Modifier and Type	Method and Description
private void	StoreScanner.addCurrentScanners(List<? extends KeyValueScanner> scanners)
static long	AbstractMemStore.addToScanners(List<? extends Segment> segments, long readPt, long order, List<KeyValueScanner> scanners)
protected static long	AbstractMemStore.addToScanners(Segment segment, long readPt, long order, List<KeyValueScanner> scanners)
private static void	StoreScanner.clearAndClose(List<KeyValueScanner> scanners)
private InternalScanner	MemStoreCompactorSegmentsIterator.createScanner(HStore store, List<KeyValueScanner> scanners) Creates the scanner for compacting the pipeline.
protected InternalScanner	StoreFlusher.createScanner(List<KeyValueScanner> snapshotScanners, long smallestReadPoint, FlushLifeCycleTracker tracker) Creates the scanner for flushing snapshot.
RegionScanner	Region.getScanner(Scan scan, List<KeyValueScanner> additionalScanners) Return an iterator that scans over the HRegion, returning the indicated columns and rows specified by the Scan.
HRegion.RegionScannerImpl	HRegion.getScanner(Scan scan, List<KeyValueScanner> additionalScanners)
private HRegion.RegionScannerImpl	HRegion.getScanner(Scan scan, List<KeyValueScanner> additionalScanners, long nonceGroup, long nonce)
private IOException	HRegion.RegionScannerImpl.handleException(List<KeyValueScanner> instantiatedScanners, Throwable t)
protected void	HRegion.RegionScannerImpl.initializeKVHeap(List<KeyValueScanner> scanners, List<KeyValueScanner> joinedScanners, HRegion region)
protected void	HRegion.RegionScannerImpl.initializeKVHeap(List<KeyValueScanner> scanners, List<KeyValueScanner> joinedScanners, HRegion region)
protected void	ReversedRegionScannerImpl.initializeKVHeap(List<KeyValueScanner> scanners, List<KeyValueScanner> joinedScanners, HRegion region)
protected void	ReversedRegionScannerImpl.initializeKVHeap(List<KeyValueScanner> scanners, List<KeyValueScanner> joinedScanners, HRegion region)
protected void	HRegion.RegionScannerImpl.initializeScanners(Scan scan, List<KeyValueScanner> additionalScanners)
protected RegionScanner	HRegion.instantiateRegionScanner(Scan scan, List<KeyValueScanner> additionalScanners)
protected HRegion.RegionScannerImpl	HRegion.instantiateRegionScanner(Scan scan, List<KeyValueScanner> additionalScanners, long nonceGroup, long nonce)
protected KeyValueHeap	ReversedStoreScanner.newKVHeap(List<? extends KeyValueScanner> scanners, CellComparator comparator)
protected KeyValueHeap	StoreScanner.newKVHeap(List<? extends KeyValueScanner> scanners, CellComparator comparator)
private void	StoreScanner.parallelSeek(List<? extends KeyValueScanner> scanners, Cell kv) Seek storefiles in parallel to optimize IO latency as much as possible
List<KeyValueScanner>	HStore.recreateScanners(List<KeyValueScanner> currentFileScanners, boolean cacheBlocks, boolean usePread, boolean isCompaction, ScanQueryMatcher matcher, byte[] startRow, boolean includeStartRow, byte[] stopRow, boolean includeStopRow, long readPt, boolean includeMemstoreScanner) Recreates the scanners on the current list of active store file scanners
protected void	StoreScanner.resetKVHeap(List<? extends KeyValueScanner> scanners, CellComparator comparator)
private void	StoreScanner.seekAllScanner(ScanInfo scanInfo, List<? extends KeyValueScanner> scanners)
protected void	ReversedStoreScanner.seekScanners(List<? extends KeyValueScanner> scanners, Cell seekKey, boolean isLazy, boolean isParallelSeek)
protected void	StoreScanner.seekScanners(List<? extends KeyValueScanner> scanners, Cell seekKey, boolean isLazy, boolean isParallelSeek) Seek the specified scanners with the given key
protected List<KeyValueScanner>	StoreScanner.selectScannersFrom(HStore store, List<? extends KeyValueScanner> allScanners) Filters the given list of scanners using Bloom filter, time range, and TTL.
void	StoreScanner.updateReaders(List<HStoreFile> sfs, List<KeyValueScanner> memStoreScanners)
void	ChangedReadersObserver.updateReaders(List<HStoreFile> sfs, List<KeyValueScanner> memStoreScanners) Notify observers.

Constructor parameters in org.apache.hadoop.hbase.regionserver with type arguments of type KeyValueScanner

Constructor and Description
KeyValueHeap(List<? extends KeyValueScanner> scanners, CellComparator comparator) Constructor.
KeyValueHeap(List<? extends KeyValueScanner> scanners, KeyValueHeap.KVScannerComparator comparator) Constructor.
RegionScannerImpl(Scan scan, List<KeyValueScanner> additionalScanners, HRegion region)
RegionScannerImpl(Scan scan, List<KeyValueScanner> additionalScanners, HRegion region, long nonceGroup, long nonce)
ReversedKeyValueHeap(List<? extends KeyValueScanner> scanners, CellComparator comparator)
ReversedRegionScannerImpl(Scan scan, List<KeyValueScanner> additionalScanners, HRegion region)
ReversedStoreScanner(Scan scan, ScanInfo scanInfo, NavigableSet<byte[]> columns, List<? extends KeyValueScanner> scanners) Constructor for testing.
StoreScanner(HStore store, ScanInfo scanInfo, List<? extends KeyValueScanner> scanners, long smallestReadPoint, long earliestPutTs, byte[] dropDeletesFromRow, byte[] dropDeletesToRow) Used for compactions that drop deletes from a limited range of rows.
StoreScanner(HStore store, ScanInfo scanInfo, List<? extends KeyValueScanner> scanners, ScanType scanType, long smallestReadPoint, long earliestPutTs) Used for store file compaction and memstore compaction.
StoreScanner(HStore store, ScanInfo scanInfo, List<? extends KeyValueScanner> scanners, ScanType scanType, long smallestReadPoint, long earliestPutTs, byte[] dropDeletesFromRow, byte[] dropDeletesToRow)
StoreScanner(ScanInfo scanInfo, OptionalInt maxVersions, ScanType scanType, List<? extends KeyValueScanner> scanners)
StoreScanner(ScanInfo scanInfo, ScanType scanType, List<? extends KeyValueScanner> scanners)
StoreScanner(Scan scan, ScanInfo scanInfo, NavigableSet<byte[]> columns, List<? extends KeyValueScanner> scanners)

Uses of KeyValueScanner in org.apache.hadoop.hbase.regionserver.handler

Fields in org.apache.hadoop.hbase.regionserver.handler declared as KeyValueScanner

Modifier and Type	Field and Description
private KeyValueScanner	ParallelSeekHandler.scanner

Constructors in org.apache.hadoop.hbase.regionserver.handler with parameters of type KeyValueScanner

Constructor and Description
ParallelSeekHandler(KeyValueScanner scanner, Cell keyValue, long readPoint, CountDownLatch latch)

Uses of KeyValueScanner in org.apache.hadoop.hbase.util

Classes in org.apache.hadoop.hbase.util that implement KeyValueScanner

Modifier and Type	Class and Description
class	CollectionBackedScanner Utility scanner that wraps a sortable collection and serves as a KeyValueScanner.