org.apache.hadoop.hbase.regionserver.compactions

Class NoLimitCompactionThroughputController

java.lang.Object

org.apache.hadoop.hbase.regionserver.compactions.NoLimitCompactionThroughputController

All Implemented Interfaces:

CompactionThroughputController, Stoppable

@InterfaceAudience.LimitedPrivate(value="Configuration")
public class NoLimitCompactionThroughputController
extends java.lang.Object
implements CompactionThroughputController

A dummy CompactionThroughputController that does nothing.

Field Summary

Fields

Modifier and Type	Field and Description
static NoLimitCompactionThroughputController	INSTANCE

Constructor Summary

Constructors

Constructor and Description
NoLimitCompactionThroughputController()

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

INSTANCE

public static final NoLimitCompactionThroughputController INSTANCE

Constructor Detail

NoLimitCompactionThroughputController

public NoLimitCompactionThroughputController()

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

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

Overrides:

toString in class java.lang.Object