@InterfaceAudience.LimitedPrivate(value="Configuration") public class PressureAwareCompactionThroughputController extends PressureAwareThroughputController
HStore.getCompactionPressure()
Modifier and Type | Field and Description |
---|---|
private static long |
DEFAULT_HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_HIGHER_BOUND |
private static long |
DEFAULT_HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_LOWER_BOUND |
private static long |
DEFAULT_HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_OFFPEAK |
private static int |
DEFAULT_HSTORE_COMPACTION_THROUGHPUT_TUNE_PERIOD |
static String |
HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_HIGHER_BOUND |
static String |
HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_LOWER_BOUND |
static String |
HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_OFFPEAK |
private static String |
HBASE_HSTORE_COMPACTION_THROUGHPUT_CONTROL_CHECK_INTERVAL |
static String |
HBASE_HSTORE_COMPACTION_THROUGHPUT_TUNE_PERIOD |
private static org.slf4j.Logger |
LOG |
private long |
maxThroughputOffpeak |
activeOperations, controlPerSize, maxThroughputLowerBound, maxThroughputUpperBound, offPeakHours, tuningPeriod
Constructor and Description |
---|
PressureAwareCompactionThroughputController() |
Modifier and Type | Method and Description |
---|---|
void |
setConf(org.apache.hadoop.conf.Configuration conf) |
void |
setup(RegionServerServices server)
Setup controller for the given region server.
|
String |
toString() |
private void |
tune(double compactionPressure) |
control, finish, getMaxThroughput, isStopped, setMaxThroughput, start, stop, throughputDesc, throughputDesc
private static final org.slf4j.Logger LOG
public static final String HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_HIGHER_BOUND
private static final long DEFAULT_HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_HIGHER_BOUND
public static final String HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_LOWER_BOUND
private static final long DEFAULT_HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_LOWER_BOUND
public static final String HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_OFFPEAK
private static final long DEFAULT_HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_OFFPEAK
public static final String HBASE_HSTORE_COMPACTION_THROUGHPUT_TUNE_PERIOD
private static final int DEFAULT_HSTORE_COMPACTION_THROUGHPUT_TUNE_PERIOD
private static final String HBASE_HSTORE_COMPACTION_THROUGHPUT_CONTROL_CHECK_INTERVAL
private long maxThroughputOffpeak
public PressureAwareCompactionThroughputController()
public void setup(RegionServerServices server)
ThroughputController
setup
in interface ThroughputController
setup
in class PressureAwareThroughputController
private void tune(double compactionPressure)
public void setConf(org.apache.hadoop.conf.Configuration conf)
setConf
in interface org.apache.hadoop.conf.Configurable
setConf
in class org.apache.hadoop.conf.Configured
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.