@InterfaceAudience.LimitedPrivate(value="Configuration") public class NoLimitCompactionThroughputController extends Object implements CompactionThroughputController
| Modifier and Type | Field and Description |
|---|---|
static NoLimitCompactionThroughputController |
INSTANCE |
| Constructor and Description |
|---|
NoLimitCompactionThroughputController() |
| Modifier and Type | Method and Description |
|---|---|
long |
control(String compactionName,
long size)
Control the compaction throughput.
|
void |
finish(String compactionName)
Finish a compaction.
|
boolean |
isStopped() |
void |
setup(RegionServerServices server)
Setup controller for the given region server.
|
void |
start(String compactionName)
Start a compaction.
|
void |
stop(String why)
Stop this service.
|
String |
toString() |
public static final NoLimitCompactionThroughputController INSTANCE
public NoLimitCompactionThroughputController()
public void setup(RegionServerServices server)
CompactionThroughputControllersetup in interface CompactionThroughputControllerpublic void start(String compactionName)
CompactionThroughputControllerstart in interface CompactionThroughputControllerpublic long control(String compactionName, long size) throws InterruptedException
CompactionThroughputControllercontrol in interface CompactionThroughputControllerInterruptedExceptionpublic void finish(String compactionName)
CompactionThroughputControllerfinish in interface CompactionThroughputControllerpublic boolean isStopped()
isStopped in interface StoppableStoppable.stop(String) has been closed.Copyright © 2007-2016 The Apache Software Foundation. All Rights Reserved.