@InterfaceAudience.LimitedPrivate(value="Configuration") public class PressureAwareFlushThroughputController extends PressureAwareThroughputController
HRegionServer.getFlushPressure()
Modifier and Type | Field and Description |
---|---|
private static long |
DEFAULT_HBASE_HSTORE_FLUSH_MAX_THROUGHPUT_LOWER_BOUND |
private static long |
DEFAULT_HBASE_HSTORE_FLUSH_MAX_THROUGHPUT_UPPER_BOUND |
private static long |
DEFAULT_HBASE_HSTORE_FLUSH_THROUGHPUT_CONTROL_CHECK_INTERVAL |
private static int |
DEFAULT_HSTORE_FLUSH_THROUGHPUT_TUNE_PERIOD |
static String |
HBASE_HSTORE_FLUSH_MAX_THROUGHPUT_LOWER_BOUND |
static String |
HBASE_HSTORE_FLUSH_MAX_THROUGHPUT_UPPER_BOUND |
static String |
HBASE_HSTORE_FLUSH_THROUGHPUT_CONTROL_CHECK_INTERVAL |
static String |
HBASE_HSTORE_FLUSH_THROUGHPUT_TUNE_PERIOD |
private static org.slf4j.Logger |
LOG |
activeOperations, controlPerSize, maxThroughputLowerBound, maxThroughputUpperBound, offPeakHours, tuningPeriod
Constructor and Description |
---|
PressureAwareFlushThroughputController() |
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 flushPressure) |
control, finish, getMaxThroughput, isStopped, setMaxThroughput, start, stop, throughputDesc, throughputDesc
private static final org.slf4j.Logger LOG
public static final String HBASE_HSTORE_FLUSH_MAX_THROUGHPUT_UPPER_BOUND
private static final long DEFAULT_HBASE_HSTORE_FLUSH_MAX_THROUGHPUT_UPPER_BOUND
public static final String HBASE_HSTORE_FLUSH_MAX_THROUGHPUT_LOWER_BOUND
private static final long DEFAULT_HBASE_HSTORE_FLUSH_MAX_THROUGHPUT_LOWER_BOUND
public static final String HBASE_HSTORE_FLUSH_THROUGHPUT_TUNE_PERIOD
private static final int DEFAULT_HSTORE_FLUSH_THROUGHPUT_TUNE_PERIOD
public static final String HBASE_HSTORE_FLUSH_THROUGHPUT_CONTROL_CHECK_INTERVAL
private static final long DEFAULT_HBASE_HSTORE_FLUSH_THROUGHPUT_CONTROL_CHECK_INTERVAL
public PressureAwareFlushThroughputController()
public void setup(RegionServerServices server)
ThroughputController
setup
in interface ThroughputController
setup
in class PressureAwareThroughputController
private void tune(double flushPressure)
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.