org.apache.hadoop.hbase.regionserver.compactions

Class PressureAwareCompactionThroughputController

java.lang.Object

Configured

org.apache.hadoop.hbase.regionserver.compactions.PressureAwareCompactionThroughputController

All Implemented Interfaces:

CompactionThroughputController, Stoppable

@InterfaceAudience.LimitedPrivate(value="Configuration")
public class PressureAwareCompactionThroughputController
extends Configured
implements CompactionThroughputController, Stoppable

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]

See Also:

Store.getCompactionPressure()

Field Summary

Fields

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 Summary

Constructors

Constructor and Description
PressureAwareCompactionThroughputController()

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_HIGHER_BOUND

public static final java.lang.String HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_HIGHER_BOUND

See Also:

Constant Field Values

HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_LOWER_BOUND

public static final java.lang.String HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_LOWER_BOUND

See Also:

Constant Field Values

HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_OFFPEAK

public static final java.lang.String HBASE_HSTORE_COMPACTION_MAX_THROUGHPUT_OFFPEAK

See Also:

Constant Field Values

HBASE_HSTORE_COMPACTION_THROUGHPUT_TUNE_PERIOD

public static final java.lang.String HBASE_HSTORE_COMPACTION_THROUGHPUT_TUNE_PERIOD

See Also:

Constant Field Values

Constructor Detail

PressureAwareCompactionThroughputController

public PressureAwareCompactionThroughputController()

Method Detail

setup

public void setup(RegionServerServices server)

Description copied from interface: CompactionThroughputController

Setup controller for the given region server.

Specified by:

setup in interface CompactionThroughputController

setConf

public void setConf(Configuration conf)

start

public void start(java.lang.String compactionName)

Description copied from interface: CompactionThroughputController

Start a compaction.

Specified by:

start in interface CompactionThroughputController

control

public long control(java.lang.String compactionName,
                    long size)
             throws java.lang.InterruptedException

Description copied from interface: CompactionThroughputController

Control the compaction throughput. Will sleep if too fast.

Specified by:

control in interface CompactionThroughputController

Returns:

the actual sleep time.

Throws:

java.lang.InterruptedException

finish

public void finish(java.lang.String compactionName)

Description copied from interface: CompactionThroughputController

Finish a compaction. Should call this method in a finally block.

Specified by:

finish in interface CompactionThroughputController

stop

public void stop(java.lang.String why)

Description copied from interface: Stoppable

Stop this service.

Specified by:

stop in interface Stoppable

Parameters:

why - Why we're stopping.

isStopped

public boolean isStopped()

Specified by:

isStopped in interface Stoppable

Returns:

True if Stoppable.stop(String) has been closed.

toString

public java.lang.String toString()