Package | Description |
---|---|
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
org.apache.hadoop.hbase.coprocessor.example | |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.regionserver.handler | |
org.apache.hadoop.hbase.util |
Modifier and Type | Method and Description |
---|---|
KeyValueScanner |
TestFromClientSide.ExceptionInReseekRegionObserver.preStoreScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
Scan scan,
java.util.NavigableSet<byte[]> targetCols,
KeyValueScanner s) |
Modifier and Type | Method and Description |
---|---|
KeyValueScanner |
TestFromClientSide.ExceptionInReseekRegionObserver.preStoreScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
Scan scan,
java.util.NavigableSet<byte[]> targetCols,
KeyValueScanner s) |
Modifier and Type | Method and Description |
---|---|
KeyValueScanner |
BaseRegionObserver.preStoreScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
Scan scan,
java.util.NavigableSet<byte[]> targetCols,
KeyValueScanner s) |
KeyValueScanner |
RegionObserver.preStoreScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
Scan scan,
java.util.NavigableSet<byte[]> targetCols,
KeyValueScanner s)
Called before a store opens a new scanner.
|
KeyValueScanner |
SimpleRegionObserver.preStoreScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
Scan scan,
java.util.NavigableSet<byte[]> targetCols,
KeyValueScanner s) |
KeyValueScanner |
TestRegionObserverScannerOpenHook.NoDataFromScan.preStoreScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
Scan scan,
java.util.NavigableSet<byte[]> targetCols,
KeyValueScanner s) |
Modifier and Type | Method and Description |
---|---|
InternalScanner |
BaseRegionObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<? extends KeyValueScanner> scanners,
ScanType scanType,
long earliestPutTs,
InternalScanner s) |
InternalScanner |
RegionObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<? extends KeyValueScanner> scanners,
ScanType scanType,
long earliestPutTs,
InternalScanner s)
|
InternalScanner |
SimpleRegionObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<? extends KeyValueScanner> scanners,
ScanType scanType,
long earliestPutTs,
InternalScanner s) |
InternalScanner |
TestRegionObserverScannerOpenHook.NoDataFromCompaction.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<? extends KeyValueScanner> scanners,
ScanType scanType,
long earliestPutTs,
InternalScanner s) |
InternalScanner |
BaseRegionObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<? extends KeyValueScanner> scanners,
ScanType scanType,
long earliestPutTs,
InternalScanner s,
CompactionRequest request) |
InternalScanner |
RegionObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<? extends KeyValueScanner> scanners,
ScanType scanType,
long earliestPutTs,
InternalScanner s,
CompactionRequest request)
Called prior to writing the
StoreFile s selected for compaction into a new
StoreFile and prior to creating the scanner used to read the input files. |
Modifier and Type | Method and Description |
---|---|
KeyValueScanner |
ZooKeeperScanPolicyObserver.preStoreScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
Scan scan,
java.util.NavigableSet<byte[]> targetCols,
KeyValueScanner s) |
Modifier and Type | Method and Description |
---|---|
InternalScanner |
ZooKeeperScanPolicyObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
KeyValueScanner memstoreScanner,
InternalScanner s) |
KeyValueScanner |
ZooKeeperScanPolicyObserver.preStoreScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
Scan scan,
java.util.NavigableSet<byte[]> targetCols,
KeyValueScanner s) |
Modifier and Type | Method and Description |
---|---|
InternalScanner |
ZooKeeperScanPolicyObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<? extends KeyValueScanner> scanners,
ScanType scanType,
long earliestPutTs,
InternalScanner s) |
Modifier and Type | Class and Description |
---|---|
protected class |
DefaultMemStore.MemStoreScanner |
class |
DelegatingKeyValueScanner |
class |
KeyValueHeap
Implements a heap merge across any number of KeyValueScanners.
|
class |
KeyValueScanFixture
A fixture that implements and presents a KeyValueScanner.
|
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 |
StoreFileScanner
KeyValueScanner adaptor over the Reader.
|
class |
StoreScanner
Scanner scans both the memstore and the Store.
|
Modifier and Type | Field and Description |
---|---|
protected KeyValueScanner |
KeyValueHeap.current
The current sub-scanner, i.e.
|
protected KeyValueScanner |
DelegatingKeyValueScanner.delegate |
Modifier and Type | Field and Description |
---|---|
protected java.util.PriorityQueue<KeyValueScanner> |
KeyValueHeap.heap |
Modifier and Type | Method and Description |
---|---|
protected KeyValueScanner |
HMobStore.createScanner(Scan scan,
java.util.NavigableSet<byte[]> targetCols,
long readPt,
KeyValueScanner scanner)
Gets the MobStoreScanner or MobReversedStoreScanner.
|
protected KeyValueScanner |
HStore.createScanner(Scan scan,
java.util.NavigableSet<byte[]> targetCols,
long readPt,
KeyValueScanner scanner) |
KeyValueScanner |
MemStoreSnapshot.getScanner() |
KeyValueScanner |
HStore.getScanner(Scan scan,
java.util.NavigableSet<byte[]> targetCols,
long readPt) |
KeyValueScanner |
Store.getScanner(Scan scan,
java.util.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.
|
KeyValueScanner |
NoOpScanPolicyObserver.preStoreScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
Scan scan,
java.util.NavigableSet<byte[]> targetCols,
KeyValueScanner s) |
KeyValueScanner |
RegionCoprocessorHost.preStoreScannerOpen(Store store,
Scan scan,
java.util.NavigableSet<byte[]> targetCols)
|
Modifier and Type | Method and Description |
---|---|
java.util.PriorityQueue<KeyValueScanner> |
KeyValueHeap.getHeap() |
java.util.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).
|
java.util.List<KeyValueScanner> |
Store.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).
|
java.util.List<KeyValueScanner> |
DefaultMemStore.getScanners(long readPt) |
java.util.List<KeyValueScanner> |
MemStore.getScanners(long readPt) |
protected java.util.List<KeyValueScanner> |
StoreScanner.getScannersNoCompaction()
Get a filtered list of scanners.
|
static java.util.List<KeyValueScanner> |
KeyValueScanFixture.scanFixture(KeyValue[]... kvArrays) |
protected java.util.List<KeyValueScanner> |
StoreScanner.selectScannersFrom(java.util.List<? extends KeyValueScanner> allScanners)
Filters the given list of scanners using Bloom filter, time range, and
TTL.
|
Modifier and Type | Method and Description |
---|---|
void |
DataBlockEncodingTool.checkStatistics(KeyValueScanner scanner,
int kvLimit)
Check statistics for given HFile for different data block encoders.
|
int |
KeyValueHeap.KVScannerComparator.compare(KeyValueScanner left,
KeyValueScanner right) |
protected KeyValueScanner |
HMobStore.createScanner(Scan scan,
java.util.NavigableSet<byte[]> targetCols,
long readPt,
KeyValueScanner scanner)
Gets the MobStoreScanner or MobReversedStoreScanner.
|
protected KeyValueScanner |
HStore.createScanner(Scan scan,
java.util.NavigableSet<byte[]> targetCols,
long readPt,
KeyValueScanner scanner) |
static boolean |
NonLazyKeyValueScanner.doRealSeek(KeyValueScanner scanner,
Cell kv,
boolean forward) |
InternalScanner |
NoOpScanPolicyObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
KeyValueScanner memstoreScanner,
InternalScanner s)
Reimplement the default behavior
|
InternalScanner |
RegionCoprocessorHost.preFlushScannerOpen(Store store,
KeyValueScanner memstoreScanner)
|
KeyValueScanner |
NoOpScanPolicyObserver.preStoreScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
Scan scan,
java.util.NavigableSet<byte[]> targetCols,
KeyValueScanner s) |
boolean |
DataBlockEncodingTool.verifyCodecs(KeyValueScanner scanner,
int kvLimit)
Verify if all data block encoders are working properly.
|
Modifier and Type | Method and Description |
---|---|
protected RegionScanner |
HRegion.getScanner(Scan scan,
java.util.List<KeyValueScanner> additionalScanners) |
protected RegionScanner |
HRegion.instantiateRegionScanner(Scan scan,
java.util.List<KeyValueScanner> additionalScanners) |
InternalScanner |
NoOpScanPolicyObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<? extends KeyValueScanner> scanners,
ScanType scanType,
long earliestPutTs,
InternalScanner s)
Reimplement the default behavior
|
protected void |
StoreScanner.resetKVHeap(java.util.List<? extends KeyValueScanner> scanners,
KeyValue.KVComparator comparator) |
protected void |
StoreScanner.seekScanners(java.util.List<? extends KeyValueScanner> scanners,
Cell seekKey,
boolean isLazy,
boolean isParallelSeek)
Seek the specified scanners with the given key
|
protected java.util.List<KeyValueScanner> |
StoreScanner.selectScannersFrom(java.util.List<? extends KeyValueScanner> allScanners)
Filters the given list of scanners using Bloom filter, time range, and
TTL.
|
Constructor and Description |
---|
DelegatingKeyValueScanner(KeyValueScanner delegate) |
MemStoreSnapshot(long id,
int cellsCount,
long size,
TimeRangeTracker timeRangeTracker,
KeyValueScanner scanner,
boolean tagsPresent) |
Constructor and Description |
---|
KeyValueHeap(java.util.List<? extends KeyValueScanner> scanners,
KeyValue.KVComparator comparator)
Constructor.
|
ReversedKeyValueHeap(java.util.List<? extends KeyValueScanner> scanners,
KeyValue.KVComparator comparator) |
StoreScanner(Scan scan,
ScanInfo scanInfo,
ScanType scanType,
java.util.NavigableSet<byte[]> columns,
java.util.List<KeyValueScanner> scanners,
long earliestPutTs,
long readPt) |
StoreScanner(Store store,
ScanInfo scanInfo,
Scan scan,
java.util.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(Store store,
ScanInfo scanInfo,
Scan scan,
java.util.List<? extends KeyValueScanner> scanners,
ScanType scanType,
long smallestReadPoint,
long earliestPutTs)
Used for compactions.
|
Constructor and Description |
---|
ParallelSeekHandler(KeyValueScanner scanner,
Cell keyValue,
long readPoint,
java.util.concurrent.CountDownLatch latch) |
Modifier and Type | Class and Description |
---|---|
class |
CollectionBackedScanner
Utility scanner that wraps a sortable collection and serves
as a KeyValueScanner.
|