org.apache.hadoop.hbase.regionserver.throttle

Class NoLimitThroughputController

java.lang.Object

org.apache.hadoop.hbase.regionserver.throttle.NoLimitThroughputController

All Implemented Interfaces:

ThroughputController, Stoppable

@InterfaceAudience.LimitedPrivate(value="Configuration")
public class NoLimitThroughputController
extends Object
implements ThroughputController

Field Summary

Fields

Modifier and Type	Field and Description
static NoLimitThroughputController	INSTANCE
private boolean	stopped

Constructor Summary

Constructors

Constructor and Description
NoLimitThroughputController()

Method Summary

Modifier and Type	Method and Description
long	control(String compactionName, long size) Control the throughput.
void	finish(String compactionName) Finish the controller.
boolean	isStopped()
void	setup(RegionServerServices server) Setup controller for the given region server.
void	start(String compactionName) Start the throughput controller.
void	stop(String why) Stop this service.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final NoLimitThroughputController INSTANCE

stopped

private boolean stopped

Constructor Detail

NoLimitThroughputController

public NoLimitThroughputController()

Method Detail

setup

public void setup(RegionServerServices server)

Description copied from interface: ThroughputController

Setup controller for the given region server.

Specified by:

setup in interface ThroughputController

start

public void start(String compactionName)

Description copied from interface: ThroughputController

Start the throughput controller.

Specified by:

start in interface ThroughputController

control

public long control(String compactionName,
                    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 compactionName)

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.

toString

public String toString()

Overrides:

toString in class Object