Package | Description |
---|---|
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
org.apache.hadoop.hbase.coprocessor.example | |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.regionserver.compactions | |
org.apache.hadoop.hbase.security.access |
Modifier and Type | Method and Description |
---|---|
default void |
RegionObserver.postCompact(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
StoreFile resultFile,
CompactionLifeCycleTracker tracker,
CompactionRequest request)
Called after compaction has completed and the new store file has been moved in to place.
|
default void |
RegionObserver.postCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
List<? extends StoreFile> selected,
CompactionLifeCycleTracker tracker,
CompactionRequest request)
Called after the
StoreFile s to compact have been selected from the available
candidates. |
default void |
RegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
StoreFile resultFile,
FlushLifeCycleTracker tracker)
Called after a Store's memstore is flushed to disk.
|
default void |
RegionObserver.postMemStoreCompaction(ObserverContext<RegionCoprocessorEnvironment> c,
Store store)
Called after the in memory compaction is finished.
|
default InternalScanner |
RegionObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
InternalScanner scanner,
ScanType scanType,
CompactionLifeCycleTracker tracker,
CompactionRequest request)
Called prior to writing the
StoreFile s selected for compaction into a new
StoreFile . |
default void |
RegionObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
ScanType scanType,
ScanOptions options,
CompactionLifeCycleTracker tracker,
CompactionRequest request)
Called before we open store scanner for compaction.
|
default void |
RegionObserver.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
List<? extends StoreFile> candidates,
CompactionLifeCycleTracker tracker)
Called prior to selecting the
StoreFiles to compact from the list of
available candidates. |
default InternalScanner |
RegionObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
InternalScanner scanner,
FlushLifeCycleTracker tracker)
Called before a Store's memstore is flushed to disk.
|
default void |
RegionObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
ScanOptions options,
FlushLifeCycleTracker tracker)
Called before we open store scanner for flush.
|
default void |
RegionObserver.preMemStoreCompaction(ObserverContext<RegionCoprocessorEnvironment> c,
Store store)
Called before in memory compaction started.
|
default InternalScanner |
RegionObserver.preMemStoreCompactionCompact(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
InternalScanner scanner)
Called before we do in memory compaction.
|
default void |
RegionObserver.preMemStoreCompactionCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
ScanOptions options)
Called before we open store scanner for in memory compaction.
|
default void |
RegionObserver.preStoreScannerOpen(ObserverContext<RegionCoprocessorEnvironment> ctx,
Store store,
ScanOptions options)
Called before a store opens a new scanner.
|
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 | Method and Description |
---|---|
Store |
Region.getStore(byte[] family)
Return the Store for the given family
|
Modifier and Type | Method and Description |
---|---|
List<? extends Store> |
Region.getStores()
Return the list of Stores managed by this region
|
Modifier and Type | Method and Description |
---|---|
default void |
CompactSplit.CompactionCompleteTracker.completed(Store store) |
void |
CompactSplit.AggregatingCompleteTracker.completed(Store store) |
Modifier and Type | Method and Description |
---|---|
default void |
CompactionLifeCycleTracker.afterExecution(Store store)
Called after compaction is executed by CompactSplitThread.
|
default void |
CompactionLifeCycleTracker.beforeExecution(Store store)
Called before compaction is executed by CompactSplitThread.
|
boolean |
CloseChecker.isSizeLimit(Store store,
long bytesWritten)
Check periodically to see if a system stop is requested every written bytes reach size limit.
|
boolean |
CloseChecker.isTimeLimit(Store store,
long now)
Check periodically to see if a system stop is requested every time.
|
default void |
CompactionLifeCycleTracker.notExecuted(Store store,
String reason)
Called if the compaction request is failed for some reason.
|
Modifier and Type | Method and Description |
---|---|
InternalScanner |
AccessController.preCompact(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
InternalScanner scanner,
ScanType scanType,
CompactionLifeCycleTracker tracker,
CompactionRequest request) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.