Package | Description |
---|---|
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
org.apache.hadoop.hbase.mob | |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.regionserver.compactions |
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) |
Modifier and Type | Method and Description |
---|---|
java.util.List<Path> |
DefaultMobStoreCompactor.compact(CompactionRequest request,
CompactionThroughputController throughputController,
User user) |
protected boolean |
DefaultMobStoreCompactor.performCompaction(Compactor.FileDetails fd,
InternalScanner scanner,
Compactor.CellSink writer,
long smallestReadPoint,
boolean cleanSeqId,
CompactionThroughputController throughputController,
boolean major)
Performs compaction on a column family with the mob flag enabled.
|
Modifier and Type | Method and Description |
---|---|
CompactionThroughputController |
CompactSplitThread.getCompactionThroughputController() |
Modifier and Type | Method and Description |
---|---|
java.util.List<StoreFile> |
HStore.compact(CompactionContext compaction,
CompactionThroughputController throughputController)
Compact the StoreFiles.
|
java.util.List<StoreFile> |
Store.compact(CompactionContext compaction,
CompactionThroughputController throughputController)
Deprecated.
see compact(CompactionContext, CompactionThroughputController, User)
|
java.util.List<StoreFile> |
HStore.compact(CompactionContext compaction,
CompactionThroughputController throughputController,
User user) |
java.util.List<StoreFile> |
Store.compact(CompactionContext compaction,
CompactionThroughputController throughputController,
User user) |
boolean |
HRegion.compact(CompactionContext compaction,
Store store,
CompactionThroughputController throughputController) |
boolean |
HRegion.compact(CompactionContext compaction,
Store store,
CompactionThroughputController throughputController,
User user) |
java.util.List<Path> |
TestCompaction.BlockingStoreMockMaker.BlockingCompactionContext.compact(CompactionThroughputController throughputController) |
java.util.List<Path> |
TestCompaction.BlockingStoreMockMaker.BlockingCompactionContext.compact(CompactionThroughputController throughputController,
User user) |
Modifier and Type | Class and Description |
---|---|
class |
NoLimitCompactionThroughputController
A dummy CompactionThroughputController that does nothing.
|
class |
PressureAwareCompactionThroughputController
A throughput controller which uses the follow schema to limit throughput
If compaction pressure is greater than 1.0, no limitation.
In off peak hours, use a fixed throughput limitation
"hbase.hstore.compaction.throughput.offpeak"
In normal hours, the max throughput is tune between
"hbase.hstore.compaction.throughput.lower.bound" and
"hbase.hstore.compaction.throughput.higher.bound", using the formula "lower +
(higer - lower) * compactionPressure", where compactionPressure is in range [0.0, 1.0]
|
Modifier and Type | Method and Description |
---|---|
static CompactionThroughputController |
CompactionThroughputControllerFactory.create(RegionServerServices server,
Configuration conf) |
Modifier and Type | Method and Description |
---|---|
static java.lang.Class<? extends CompactionThroughputController> |
CompactionThroughputControllerFactory.getThroughputControllerClass(Configuration conf) |
Modifier and Type | Method and Description |
---|---|
java.util.List<Path> |
DefaultCompactor.compact(CompactionRequest request,
CompactionThroughputController throughputController,
User user)
Do a minor/major compaction on an explicit set of storefiles from a Store.
|
protected java.util.List<Path> |
Compactor.compact(CompactionRequest request,
Compactor.InternalScannerFactory scannerFactory,
Compactor.CellSinkFactory<T> sinkFactory,
CompactionThroughputController throughputController,
User user) |
java.util.List<Path> |
StripeCompactor.compact(CompactionRequest request,
int targetCount,
long targetSize,
byte[] left,
byte[] right,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
CompactionThroughputController throughputController,
User user) |
java.util.List<Path> |
StripeCompactor.compact(CompactionRequest request,
java.util.List<byte[]> targetBoundaries,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
CompactionThroughputController throughputController,
User user) |
java.util.List<Path> |
DateTieredCompactor.compact(CompactionRequest request,
java.util.List<java.lang.Long> lowerBoundaries,
CompactionThroughputController throughputController,
User user) |
abstract java.util.List<Path> |
CompactionContext.compact(CompactionThroughputController throughputController)
Runs the compaction based on current selection.
|
abstract java.util.List<Path> |
CompactionContext.compact(CompactionThroughputController throughputController,
User user) |
java.util.List<Path> |
StripeCompactionPolicy.StripeCompactionRequest.execute(StripeCompactor compactor,
CompactionThroughputController throughputController) |
abstract java.util.List<Path> |
StripeCompactionPolicy.StripeCompactionRequest.execute(StripeCompactor compactor,
CompactionThroughputController throughputController,
User user)
Executes the request against compactor (essentially, just calls correct overload of
compact method), to simulate more dynamic dispatch.
|
protected boolean |
Compactor.performCompaction(Compactor.FileDetails fd,
InternalScanner scanner,
Compactor.CellSink writer,
long smallestReadPoint,
boolean cleanSeqId,
CompactionThroughputController throughputController,
boolean major)
Performs the compaction.
|