@InterfaceAudience.LimitedPrivate(value="Configuration") public class PressureAwareCompactionThroughputController extends Configured implements CompactionThroughputController, Stoppable
Store.getCompactionPressure()
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_HIGHER_BOUND |
static java.lang.String |
HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_LOWER_BOUND |
static java.lang.String |
HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_OFFPEAK |
static java.lang.String |
HBASE_HSTORE_COMPACTION_THROUGHPUT_TUNE_PERIOD |
Constructor and Description |
---|
PressureAwareCompactionThroughputController() |
Modifier and Type | Method and Description |
---|---|
long |
control(java.lang.String compactionName,
long size)
Control the compaction throughput.
|
void |
finish(java.lang.String compactionName)
Finish a compaction.
|
boolean |
isStopped() |
void |
setConf(Configuration conf) |
void |
setup(RegionServerServices server)
Setup controller for the given region server.
|
void |
start(java.lang.String compactionName)
Start a compaction.
|
void |
stop(java.lang.String why)
Stop this service.
|
java.lang.String |
toString() |
public static final java.lang.String HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_HIGHER_BOUND
public static final java.lang.String HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_LOWER_BOUND
public static final java.lang.String HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_OFFPEAK
public static final java.lang.String HBASE_HSTORE_COMPACTION_THROUGHPUT_TUNE_PERIOD
public PressureAwareCompactionThroughputController()
public void setup(RegionServerServices server)
CompactionThroughputController
setup
in interface CompactionThroughputController
public void setConf(Configuration conf)
public void start(java.lang.String compactionName)
CompactionThroughputController
start
in interface CompactionThroughputController
public long control(java.lang.String compactionName, long size) throws java.lang.InterruptedException
CompactionThroughputController
control
in interface CompactionThroughputController
java.lang.InterruptedException
public void finish(java.lang.String compactionName)
CompactionThroughputController
finish
in interface CompactionThroughputController
public void stop(java.lang.String why)
Stoppable
public boolean isStopped()
isStopped
in interface Stoppable
Stoppable.stop(String)
has been closed.public java.lang.String toString()