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.mob | |
org.apache.hadoop.hbase.mob.compactions | |
org.apache.hadoop.hbase.namespace | |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.regionserver.compactions | |
org.apache.hadoop.hbase.security.access |
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 |
---|---|
boolean |
TestRegionObserverScannerOpenHook.CompactionCompletionNotifyingRegion.compact(CompactionContext compaction,
Store store,
CompactionThroughputController throughputController) |
boolean |
TestRegionObserverScannerOpenHook.CompactionCompletionNotifyingRegion.compact(CompactionContext compaction,
Store store,
CompactionThroughputController throughputController,
User user) |
void |
BaseRegionObserver.postCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
StoreFile resultFile) |
void |
RegionObserver.postCompact(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
StoreFile resultFile)
Deprecated.
|
void |
SimpleRegionObserver.postCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
StoreFile resultFile) |
void |
TestCoprocessorInterface.CoprocessorImpl.postCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
StoreFile resultFile) |
void |
TestRegionObserverInterface.EvenOnlyCompactor.postCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
StoreFile resultFile) |
void |
BaseRegionObserver.postCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
StoreFile resultFile,
CompactionRequest request) |
void |
RegionObserver.postCompact(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
StoreFile resultFile,
CompactionRequest request)
Called after compaction has completed and the new store file has been moved in to place.
|
void |
BaseRegionObserver.postCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
<any> selected) |
void |
RegionObserver.postCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
<any> selected)
Deprecated.
use
#postCompactSelection(ObserverContext, Store, ImmutableList,
CompactionRequest) instead. |
void |
SimpleRegionObserver.postCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
<any> selected) |
void |
BaseRegionObserver.postCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
<any> selected,
CompactionRequest request) |
void |
RegionObserver.postCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
<any> selected,
CompactionRequest request)
Called after the
StoreFile s to compact have been selected from the available
candidates. |
void |
BaseRegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
StoreFile resultFile) |
void |
RegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
StoreFile resultFile)
Called after a Store's memstore is flushed to disk.
|
void |
SimpleRegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
StoreFile resultFile) |
InternalScanner |
BaseRegionObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
InternalScanner scanner,
ScanType scanType) |
InternalScanner |
RegionObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
InternalScanner scanner,
ScanType scanType)
Deprecated.
|
InternalScanner |
SimpleRegionObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
InternalScanner scanner,
ScanType scanType) |
InternalScanner |
TestCoprocessorInterface.CoprocessorImpl.preCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
InternalScanner scanner,
ScanType scanType) |
InternalScanner |
TestRegionObserverInterface.EvenOnlyCompactor.preCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
InternalScanner scanner,
ScanType scanType) |
InternalScanner |
BaseRegionObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
InternalScanner scanner,
ScanType scanType,
CompactionRequest request) |
InternalScanner |
RegionObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
InternalScanner scanner,
ScanType scanType,
CompactionRequest request)
Called prior to writing the
StoreFile s selected for compaction into a new
StoreFile . |
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. |
void |
BaseRegionObserver.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<StoreFile> candidates) |
void |
RegionObserver.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<StoreFile> candidates)
Deprecated.
|
void |
SimpleRegionObserver.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<StoreFile> candidates) |
void |
BaseRegionObserver.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<StoreFile> candidates,
CompactionRequest request) |
void |
RegionObserver.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<StoreFile> candidates,
CompactionRequest request)
Called prior to selecting the
StoreFiles to compact from the list of
available candidates. |
InternalScanner |
BaseRegionObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
InternalScanner scanner) |
InternalScanner |
RegionObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
InternalScanner scanner)
Called before a Store's memstore is flushed to disk.
|
InternalScanner |
SimpleRegionObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
InternalScanner scanner) |
InternalScanner |
BaseRegionObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
KeyValueScanner memstoreScanner,
InternalScanner s) |
InternalScanner |
RegionObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
KeyValueScanner memstoreScanner,
InternalScanner s)
Called before a memstore is flushed to disk and prior to creating the scanner to read from
the memstore.
|
InternalScanner |
SimpleRegionObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
KeyValueScanner memstoreScanner,
InternalScanner s) |
InternalScanner |
TestRegionObserverScannerOpenHook.NoDataFromFlush.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
KeyValueScanner memstoreScanner,
InternalScanner s) |
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 |
---|---|
protected ScanInfo |
ZooKeeperScanPolicyObserver.getScanInfo(Store store,
RegionCoprocessorEnvironment e) |
InternalScanner |
ZooKeeperScanPolicyObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<? extends KeyValueScanner> scanners,
ScanType scanType,
long earliestPutTs,
InternalScanner s) |
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 |
---|---|
protected void |
MobStoreEngine.createCompactor(Configuration conf,
Store store)
Creates the DefaultMobCompactor.
|
protected void |
MobStoreEngine.createStoreFlusher(Configuration conf,
Store store) |
Constructor and Description |
---|
DefaultMobStoreCompactor(Configuration conf,
Store store) |
DefaultMobStoreFlusher(Configuration conf,
Store store) |
Modifier and Type | Method and Description |
---|---|
void |
TestMobCompactor.CompactTwoLatestHfilesCopro.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<StoreFile> candidates,
CompactionRequest request) |
Modifier and Type | Method and Description |
---|---|
void |
TestNamespaceAuditor.CustomObserver.postCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
StoreFile resultFile) |
Modifier and Type | Class and Description |
---|---|
class |
HMobStore
The store implementation to save MOBs (medium objects), it extends the HStore.
|
class |
HStore
A Store holds a column family in a Region.
|
Modifier and Type | Field and Description |
---|---|
protected Store |
StoreScanner.store |
Modifier and Type | Field and Description |
---|---|
protected java.util.Map<byte[],Store> |
HRegion.stores |
Modifier and Type | Method and Description |
---|---|
Store |
TestCompaction.BlockingStoreMockMaker.createStoreMock(int priority,
java.lang.String name) |
Store |
StatefulStoreMockMaker.createStoreMock(java.lang.String name) |
Store |
TestCompaction.BlockingStoreMockMaker.createStoreMock(java.lang.String name) |
Store |
HRegion.getStore(byte[] column) |
Store |
Region.getStore(byte[] family)
Return the Store for the given family
|
Modifier and Type | Method and Description |
---|---|
java.util.List<Store> |
HRegion.getStores() |
java.util.List<Store> |
Region.getStores()
Return the list of Stores managed by this region
|
java.util.Collection<Store> |
FlushAllStoresPolicy.selectStoresToFlush() |
java.util.Collection<Store> |
FlushLargeStoresPolicy.selectStoresToFlush() |
abstract java.util.Collection<Store> |
FlushPolicy.selectStoresToFlush() |
Modifier and Type | Method and Description |
---|---|
boolean |
HRegion.compact(CompactionContext compaction,
Store store,
CompactionThroughputController throughputController) |
boolean |
HRegion.compact(CompactionContext compaction,
Store store,
CompactionThroughputController throughputController,
User user) |
static StoreEngine<?,?,?,?> |
StoreEngine.create(Store store,
Configuration conf,
KeyValue.KVComparator kvComparator)
Create the StoreEngine configured for the given Store.
|
protected void |
DefaultStoreEngine.createCompactionPolicy(Configuration conf,
Store store) |
protected void |
DefaultStoreEngine.createCompactor(Configuration conf,
Store store) |
protected void |
DateTieredStoreEngine.createComponents(Configuration conf,
Store store,
KeyValue.KVComparator kvComparator) |
protected void |
DefaultStoreEngine.createComponents(Configuration conf,
Store store,
KeyValue.KVComparator kvComparator) |
protected abstract void |
StoreEngine.createComponents(Configuration conf,
Store store,
KeyValue.KVComparator kvComparator)
Create the StoreEngine's components.
|
protected void |
StripeStoreEngine.createComponents(Configuration conf,
Store store,
KeyValue.KVComparator comparator) |
protected StoreEngine<?,?,?,?> |
HMobStore.createStoreEngine(Store store,
Configuration conf,
KeyValue.KVComparator cellComparator)
Creates the mob store engine.
|
protected StoreEngine<?,?,?,?> |
HStore.createStoreEngine(Store store,
Configuration conf,
KeyValue.KVComparator kvComparator)
Creates the store engine configured for the given Store.
|
protected void |
DefaultStoreEngine.createStoreFlusher(Configuration conf,
Store store) |
void |
RegionCoprocessorHost.postCompact(Store store,
StoreFile resultFile,
CompactionRequest request)
Called after the store compaction has completed.
|
void |
RegionCoprocessorHost.postCompactSelection(Store store,
<any> selected,
CompactionRequest request)
Called after the
StoreFile s to be compacted have been selected from the available
candidates. |
void |
RegionCoprocessorHost.postFlush(Store store,
StoreFile storeFile)
Invoked after a memstore flush
|
InternalScanner |
TestHRegionServerBulkLoad.MyObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
InternalScanner scanner,
ScanType scanType) |
InternalScanner |
RegionCoprocessorHost.preCompact(Store store,
InternalScanner scanner,
ScanType scanType,
CompactionRequest request)
Called prior to rewriting the store files selected for compaction
|
InternalScanner |
NoOpScanPolicyObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
java.util.List<? extends KeyValueScanner> scanners,
ScanType scanType,
long earliestPutTs,
InternalScanner s)
Reimplement the default behavior
|
InternalScanner |
RegionCoprocessorHost.preCompactScannerOpen(Store store,
java.util.List<StoreFileScanner> scanners,
ScanType scanType,
long earliestPutTs,
CompactionRequest request)
|
boolean |
RegionCoprocessorHost.preCompactSelection(Store store,
java.util.List<StoreFile> candidates,
CompactionRequest request)
Called prior to selecting the
StoreFile s for compaction from the list of currently
available candidates. |
InternalScanner |
RegionCoprocessorHost.preFlush(Store store,
InternalScanner scanner)
Invoked before a memstore flush
|
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) |
KeyValueScanner |
RegionCoprocessorHost.preStoreScannerOpen(Store store,
Scan scan,
java.util.NavigableSet<byte[]> targetCols)
|
CompactionRequest |
CompactionRequestor.requestCompaction(Region r,
Store s,
java.lang.String why,
CompactionRequest request) |
CompactionRequest |
CompactSplitThread.requestCompaction(Region r,
Store s,
java.lang.String why,
CompactionRequest request) |
CompactionRequest |
CompactionRequestor.requestCompaction(Region r,
Store s,
java.lang.String why,
int pri,
CompactionRequest request,
User user) |
CompactionRequest |
CompactSplitThread.requestCompaction(Region r,
Store s,
java.lang.String why,
int priority,
CompactionRequest request,
User user) |
void |
CompactSplitThread.requestSystemCompaction(Region r,
Store s,
java.lang.String why) |
protected boolean |
HRegion.restoreEdit(Store s,
Cell cell)
Used by tests
|
Modifier and Type | Method and Description |
---|---|
protected Region.FlushResult |
HRegion.internalFlushcache(WAL wal,
long myseqid,
java.util.Collection<Store> storesToFlush,
MonitoredTask status,
boolean writeFlushWalMarker)
Flush the memstore.
|
protected Region.FlushResult |
HRegion.internalFlushCacheAndCommit(WAL wal,
MonitoredTask status,
org.apache.hadoop.hbase.regionserver.HRegion.PrepareFlushResult prepareResult,
java.util.Collection<Store> storesToFlush) |
protected org.apache.hadoop.hbase.regionserver.HRegion.PrepareFlushResult |
HRegion.internalPrepareFlushCache(WAL wal,
long myseqid,
java.util.Collection<Store> storesToFlush,
MonitoredTask status,
boolean writeFlushWalMarker) |
java.util.List<CompactionRequest> |
CompactionRequestor.requestCompaction(Region r,
java.lang.String why,
int pri,
java.util.List<Pair<CompactionRequest,Store>> requests,
User user) |
java.util.List<CompactionRequest> |
CompactSplitThread.requestCompaction(Region r,
java.lang.String why,
int p,
java.util.List<Pair<CompactionRequest,Store>> requests,
User user) |
java.util.List<CompactionRequest> |
CompactionRequestor.requestCompaction(Region r,
java.lang.String why,
java.util.List<Pair<CompactionRequest,Store>> requests) |
java.util.List<CompactionRequest> |
CompactSplitThread.requestCompaction(Region r,
java.lang.String why,
java.util.List<Pair<CompactionRequest,Store>> requests) |
Constructor and Description |
---|
DefaultStoreFlusher(Configuration conf,
Store store) |
DummyCompactor(Configuration conf,
Store store) |
DummyCompactor(Configuration conf,
Store store) |
DummyStoreFlusher(Configuration conf,
Store store) |
MobStoreScanner(Store store,
ScanInfo scanInfo,
Scan scan,
java.util.NavigableSet<byte[]> columns,
long readPt) |
StoreScanner(Store store,
boolean cacheBlocks,
Scan scan,
java.util.NavigableSet<byte[]> columns,
long ttl,
int minVersions,
long readPt)
An internal constructor.
|
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.
|
StoreScanner(Store store,
ScanInfo scanInfo,
Scan scan,
java.util.NavigableSet<byte[]> columns,
long readPt)
Opens a scanner across memstore, snapshot, and all StoreFiles.
|
StripeStoreFlusher(Configuration conf,
Store store,
StripeCompactionPolicy policy,
StripeStoreFileManager stripes) |
Modifier and Type | Field and Description |
---|---|
protected Store |
Compactor.store |
Modifier and Type | Method and Description |
---|---|
protected InternalScanner |
Compactor.createScanner(Store store,
java.util.List<StoreFileScanner> scanners,
long smallestReadPoint,
long earliestPutTs,
byte[] dropDeletesFromRow,
byte[] dropDeletesToRow) |
protected InternalScanner |
Compactor.createScanner(Store store,
java.util.List<StoreFileScanner> scanners,
ScanType scanType,
long smallestReadPoint,
long earliestPutTs) |
Constructor and Description |
---|
AbstractMultiOutputCompactor(Configuration conf,
Store store) |
DateTieredCompactor(Configuration conf,
Store store) |
DefaultCompactor(Configuration conf,
Store store) |
StripeCompactor(Configuration conf,
Store store) |
Modifier and Type | Method and Description |
---|---|
InternalScanner |
AccessController.preCompact(ObserverContext<RegionCoprocessorEnvironment> e,
Store store,
InternalScanner scanner,
ScanType scanType) |