Package 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

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

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	Description
protected final ConcurrentMap<String,PressureAwareThroughputController.ActiveOperation>	activeOperations
protected long	controlPerSize
private static final 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	Description
PressureAwareThroughputController()

Method Summary

Modifier and Type	Method	Description
long	control(String opName, long size)	Control the throughput.
void	finish(String opName)	Finish the controller.
double	getMaxThroughput()
boolean	isStopped()	Returns True if Stoppable.stop(String) has been closed.
void	setMaxThroughput(double maxThroughput)
abstract void	setup(RegionServerServices server)	Setup controller for the given region server.
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 Details

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 Details

PressureAwareThroughputController

public PressureAwareThroughputController()

Method Details

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

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

Description copied from interface: Stoppable

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

Specified by:

isStopped in interface Stoppable

getMaxThroughput

public double getMaxThroughput()

setMaxThroughput

public void setMaxThroughput(double maxThroughput)