org.apache.hadoop.hbase.regionserver.throttle

Class PressureAwareThroughputController

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.hbase.regionserver.throttle.PressureAwareThroughputController

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, ThroughputController, Stoppable

Direct Known Subclasses:

PressureAwareCompactionThroughputController, PressureAwareFlushThroughputController

@InterfaceAudience.LimitedPrivate(value="Configuration")
public abstract class PressureAwareThroughputController
extends org.apache.hadoop.conf.Configured
implements ThroughputController, Stoppable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	PressureAwareThroughputController.ActiveOperation Stores the information of one controlled compaction.

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentMap<String,PressureAwareThroughputController.ActiveOperation>	activeOperations
protected long	controlPerSize
private static org.slf4j.Logger	LOG
private double	maxThroughput
protected long	maxThroughputLowerBound
private double	maxThroughputPerOperation
protected long	maxThroughputUpperBound
protected OffPeakHours	offPeakHours
private boolean	stopped
protected int	tuningPeriod

Constructor Summary

Constructors

Constructor and Description
PressureAwareThroughputController()

Method Summary

Modifier and Type	Method and Description
long	control(String opName, long size) Control the throughput.
void	finish(String opName) Finish the controller.
double	getMaxThroughput()
boolean	isStopped()
void	setMaxThroughput(double maxThroughput)
abstract void	setup(RegionServerServices server) Setup controller for the given region server.
protected abstract boolean	skipControl(long deltaSize, long controlSize) Check whether to skip control given delta size and control size
void	start(String opName) Start the throughput controller.
void	stop(String why) Stop this service.
protected String	throughputDesc(double speed)
protected String	throughputDesc(long deltaSize, long elapsedTime)

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

maxThroughputUpperBound

protected long maxThroughputUpperBound

maxThroughputLowerBound

protected long maxThroughputLowerBound

offPeakHours

protected OffPeakHours offPeakHours

controlPerSize

protected long controlPerSize

tuningPeriod

protected int tuningPeriod

maxThroughput

private volatile double maxThroughput

maxThroughputPerOperation

private volatile double maxThroughputPerOperation

activeOperations

protected final ConcurrentMap<String,PressureAwareThroughputController.ActiveOperation> activeOperations

stopped

private volatile boolean stopped

Constructor Detail

PressureAwareThroughputController

public PressureAwareThroughputController()

Method Detail

setup

public abstract void setup(RegionServerServices server)

Description copied from interface: ThroughputController

Setup controller for the given region server.

Specified by:

setup in interface ThroughputController

throughputDesc

protected String throughputDesc(long deltaSize,
                                long elapsedTime)

throughputDesc

protected String throughputDesc(double speed)

start

public void start(String opName)

Description copied from interface: ThroughputController

Start the throughput controller.

Specified by:

start in interface ThroughputController

control

public long control(String opName,
                    long size)
             throws InterruptedException

Description copied from interface: ThroughputController

Control the throughput. Will sleep if too fast.

Specified by:

control in interface ThroughputController

Returns:

the actual sleep time.

Throws:

InterruptedException

skipControl

protected abstract boolean skipControl(long deltaSize,
                                       long controlSize)

Check whether to skip control given delta size and control size

Parameters:

deltaSize - Delta size since last control

controlSize - Size limit to perform control

Returns:

a boolean indicates whether to skip this control

finish

public void finish(String opName)

Description copied from interface: ThroughputController

Finish the controller. Should call this method in a finally block.

Specified by:

finish in interface ThroughputController

stop

public void stop(String why)

Description copied from interface: Stoppable

Stop this service. Implementers should favor logging errors over throwing RuntimeExceptions.

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.

getMaxThroughput

public double getMaxThroughput()

setMaxThroughput

public void setMaxThroughput(double maxThroughput)