class
org.apache.hadoop.hbase.regionserver.KeyValueHeap
Implements a heap merge across any number of KeyValueScanners.
class
org.apache.hadoop.hbase.regionserver.MobStoreScanner
Scanner scans both the memstore and the MOB Store.
class
org.apache.hadoop.hbase.regionserver.NonLazyKeyValueScanner
A "non-lazy" scanner which always does a real seek operation.
class
org.apache.hadoop.hbase.regionserver.NonReversedNonLazyKeyValueScanner
A "non-reversed & non-lazy" scanner which does not support backward scanning and always does
a real seek operation.
class
org.apache.hadoop.hbase.regionserver.ReversedKeyValueHeap
ReversedKeyValueHeap is used for supporting reversed scanning.
class
org.apache.hadoop.hbase.regionserver.ReversedMobStoreScanner
ReversedMobStoreScanner extends from ReversedStoreScanner, and is used to support reversed
scanning in both the memstore and the MOB store.
class
org.apache.hadoop.hbase.regionserver.ReversedStoreScanner
ReversedStoreScanner extends from StoreScanner, and is used to support reversed scanning.
class
org.apache.hadoop.hbase.regionserver.SegmentScanner
A scanner of a single memstore segment.
class
org.apache.hadoop.hbase.regionserver.SnapshotSegmentScanner
A basic SegmentScanner used against an ImmutableScanner snapshot Used flushing where we do a
single pass, no reverse scanning or inserts happening.
class
org.apache.hadoop.hbase.regionserver.StoreFileScanner
KeyValueScanner adaptor over the Reader.
class
org.apache.hadoop.hbase.regionserver.StoreScanner
Scanner scans both the memstore and the Store.
protected org.apache.hadoop.hbase.regionserver.KeyValueScanner
HMobStore.createScanner(org.apache.hadoop.hbase.client.Scan scan,
org.apache.hadoop.hbase.regionserver.ScanInfo scanInfo,
NavigableSet<byte[]> targetCols,
long readPt)
Gets the MobStoreScanner or MobReversedStoreScanner.
protected org.apache.hadoop.hbase.regionserver.KeyValueScanner
HStore.createScanner(org.apache.hadoop.hbase.client.Scan scan,
org.apache.hadoop.hbase.regionserver.ScanInfo scanInfo,
NavigableSet<byte[]> targetCols,
long readPt)
org.apache.hadoop.hbase.regionserver.KeyValueScanner
CompositeImmutableSegment.getScanner(long readPoint)
Creates the scanner for the given read point
org.apache.hadoop.hbase.regionserver.KeyValueScanner
HStore.getScanner(org.apache.hadoop.hbase.client.Scan scan,
NavigableSet<byte[]> targetCols,
long readPt)
Return a scanner for both the memstore and the HStore files.
protected org.apache.hadoop.hbase.regionserver.KeyValueScanner
Segment.getScanner(long readPoint)
Creates the scanner for the given read point
protected org.apache.hadoop.hbase.regionserver.KeyValueScanner
KeyValueHeap.pollRealKV()
Fetches the top sub-scanner from the priority queue, ensuring that a real seek has been done on
it.
protected List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>
CompactingMemStore.createList(int capacity)
PriorityQueue<org.apache.hadoop.hbase.regionserver.KeyValueScanner>
KeyValueHeap.getHeap()
List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>
CompactingMemStore.getScanners(long readPt)
This method is protected under HStore#lock
read lock.
List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>
CompositeImmutableSegment.getScanners(long readPoint)
List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>
DefaultMemStore.getScanners(long readPt)
List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>
HStore.getScanners(boolean cacheBlocks,
boolean isGet,
boolean usePread,
boolean isCompaction,
org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher matcher,
byte[] startRow,
byte[] stopRow,
long readPt,
boolean onlyLatestVersion)
Get all scanners with no filtering based on TTL (that happens further down the line).
List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>
HStore.getScanners(boolean cacheBlocks,
boolean usePread,
boolean isCompaction,
org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher matcher,
byte[] startRow,
boolean includeStartRow,
byte[] stopRow,
boolean includeStopRow,
long readPt,
boolean onlyLatestVersion)
Get all scanners with no filtering based on TTL (that happens further down the line).
List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>
HStore.getScanners(List<org.apache.hadoop.hbase.regionserver.HStoreFile> files,
boolean cacheBlocks,
boolean isGet,
boolean usePread,
boolean isCompaction,
org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher matcher,
byte[] startRow,
byte[] stopRow,
long readPt,
boolean includeMemstoreScanner,
boolean onlyLatestVersion)
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<org.apache.hadoop.hbase.regionserver.KeyValueScanner>
HStore.getScanners(List<org.apache.hadoop.hbase.regionserver.HStoreFile> files,
boolean cacheBlocks,
boolean usePread,
boolean isCompaction,
org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher matcher,
byte[] startRow,
boolean includeStartRow,
byte[] stopRow,
boolean includeStopRow,
long readPt,
boolean includeMemstoreScanner,
boolean onlyLatestVersion)
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<org.apache.hadoop.hbase.regionserver.KeyValueScanner>
MemStore.getScanners(long readPt)
List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>
MemStoreSnapshot.getScanners()
Create new SnapshotSegmentScanner
s for iterating over the snapshot.
List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>
Segment.getScanners(long readPoint)
List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>
HStore.recreateScanners(List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> currentFileScanners,
boolean cacheBlocks,
boolean usePread,
boolean isCompaction,
org.apache.hadoop.hbase.regionserver.querymatcher.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<org.apache.hadoop.hbase.regionserver.KeyValueScanner>
StoreScanner.selectScannersFrom(org.apache.hadoop.hbase.regionserver.HStore store,
List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> allScanners)
Filters the given list of scanners using Bloom filter, time range, and TTL.
int
KeyValueHeap.KVScannerComparator.compare(org.apache.hadoop.hbase.regionserver.KeyValueScanner left,
org.apache.hadoop.hbase.regionserver.KeyValueScanner right)
static boolean
NonLazyKeyValueScanner.doRealSeek(org.apache.hadoop.hbase.regionserver.KeyValueScanner scanner,
org.apache.hadoop.hbase.ExtendedCell kv,
boolean forward)
protected static void
AbstractMemStore.addToScanners(org.apache.hadoop.hbase.regionserver.Segment segment,
long readPt,
List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners)
org.apache.hadoop.hbase.regionserver.RegionScannerImpl
HRegion.getScanner(org.apache.hadoop.hbase.client.Scan scan,
List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> additionalScanners)
org.apache.hadoop.hbase.regionserver.RegionScanner
Region.getScanner(org.apache.hadoop.hbase.client.Scan scan,
List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> additionalScanners)
Return an iterator that scans over the HRegion, returning the indicated columns and rows
specified by the Scan
.
protected org.apache.hadoop.hbase.regionserver.RegionScannerImpl
HRegion.instantiateRegionScanner(org.apache.hadoop.hbase.client.Scan scan,
List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> additionalScanners,
long nonceGroup,
long nonce)
protected org.apache.hadoop.hbase.regionserver.KeyValueHeap
ReversedStoreScanner.newKVHeap(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners,
CellComparator comparator)
protected org.apache.hadoop.hbase.regionserver.KeyValueHeap
StoreScanner.newKVHeap(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners,
CellComparator comparator)
List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>
HStore.recreateScanners(List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> currentFileScanners,
boolean cacheBlocks,
boolean usePread,
boolean isCompaction,
org.apache.hadoop.hbase.regionserver.querymatcher.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 org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners,
CellComparator comparator)
protected void
ReversedStoreScanner.seekScanners(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners,
org.apache.hadoop.hbase.ExtendedCell seekKey,
boolean isLazy,
boolean isParallelSeek)
protected void
StoreScanner.seekScanners(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners,
org.apache.hadoop.hbase.ExtendedCell seekKey,
boolean isLazy,
boolean isParallelSeek)
Seek the specified scanners with the given key
protected List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>
StoreScanner.selectScannersFrom(org.apache.hadoop.hbase.regionserver.HStore store,
List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> allScanners)
Filters the given list of scanners using Bloom filter, time range, and TTL.