@InterfaceAudience.LimitedPrivate(value="Configuration") public class NoLimitThroughputController extends Object implements ThroughputController
Modifier and Type | Field and Description |
---|---|
static NoLimitThroughputController |
INSTANCE |
private boolean |
stopped |
Constructor and Description |
---|
NoLimitThroughputController() |
Modifier and Type | Method and Description |
---|---|
long |
control(String compactionName,
long size)
Control the throughput.
|
void |
finish(String compactionName)
Finish the controller.
|
boolean |
isStopped()
Returns True if
Stoppable.stop(String) has been closed. |
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() |
public static final NoLimitThroughputController INSTANCE
private boolean stopped
public NoLimitThroughputController()
public void setup(RegionServerServices server)
ThroughputController
setup
in interface ThroughputController
public void start(String compactionName)
ThroughputController
start
in interface ThroughputController
public long control(String compactionName, long size) throws InterruptedException
ThroughputController
control
in interface ThroughputController
InterruptedException
public void finish(String compactionName)
ThroughputController
finish
in interface ThroughputController
public void stop(String why)
Stoppable
public boolean isStopped()
Stoppable
Stoppable.stop(String)
has been closed.Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.