public class CompactSplit extends java.lang.Object implements CompactionRequester, PropagatingConfigurationObserver
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_REGION_SERVER_REGION_SPLIT_LIMIT |
static java.lang.String |
LARGE_COMPACTION_THREADS |
static int |
LARGE_COMPACTION_THREADS_DEFAULT |
static java.lang.String |
REGION_SERVER_REGION_SPLIT_LIMIT |
static java.lang.String |
SMALL_COMPACTION_THREADS |
static int |
SMALL_COMPACTION_THREADS_DEFAULT |
static java.lang.String |
SPLIT_THREADS |
static int |
SPLIT_THREADS_DEFAULT |
Modifier and Type | Method and Description |
---|---|
void |
clearLongCompactionsQueue() |
void |
clearShortCompactionsQueue() |
void |
deregisterChildren(ConfigurationManager manager)
Needs to be called to deregister the children from the manager.
|
java.lang.String |
dumpQueue() |
int |
getCompactionQueueSize()
Returns the current size of the queue containing regions that are
processed.
|
ThroughputController |
getCompactionThroughputController() |
int |
getLargeCompactionQueueSize() |
protected int |
getLargeCompactionThreadNum() |
int |
getRegionSplitLimit() |
int |
getSmallCompactionQueueSize() |
protected int |
getSmallCompactionThreadNum() |
int |
getSplitQueueSize() |
protected int |
getSplitThreadNum() |
void |
onConfigurationChange(Configuration newConf)
This method would be called by the
ConfigurationManager
object when the Configuration object is reloaded from disk. |
void |
registerChildren(ConfigurationManager manager)
Needs to be called to register the children to the manager.
|
void |
requestCompaction(HRegion region,
HStore store,
java.lang.String why,
int priority,
CompactionLifeCycleTracker tracker,
User user)
Request compaction on the given store.
|
void |
requestCompaction(HRegion region,
java.lang.String why,
int priority,
CompactionLifeCycleTracker tracker,
User user)
Request compaction on all the stores of the given region.
|
boolean |
requestSplit(Region r) |
void |
requestSplit(Region r,
byte[] midKey) |
void |
requestSplit(Region r,
byte[] midKey,
User user) |
void |
requestSystemCompaction(HRegion region,
HStore store,
java.lang.String why) |
void |
requestSystemCompaction(HRegion region,
java.lang.String why) |
java.lang.String |
toString() |
public static final java.lang.String LARGE_COMPACTION_THREADS
public static final int LARGE_COMPACTION_THREADS_DEFAULT
public static final java.lang.String SMALL_COMPACTION_THREADS
public static final int SMALL_COMPACTION_THREADS_DEFAULT
public static final java.lang.String SPLIT_THREADS
public static final int SPLIT_THREADS_DEFAULT
public static final java.lang.String REGION_SERVER_REGION_SPLIT_LIMIT
public static final int DEFAULT_REGION_SERVER_REGION_SPLIT_LIMIT
public java.lang.String toString()
toString
in class java.lang.Object
public java.lang.String dumpQueue()
public boolean requestSplit(Region r)
public void requestSplit(Region r, byte[] midKey)
public void requestSplit(Region r, byte[] midKey, User user)
public void requestCompaction(HRegion region, java.lang.String why, int priority, CompactionLifeCycleTracker tracker, User user) throws java.io.IOException
CompactionRequester
requestCompaction
in interface CompactionRequester
java.io.IOException
public void requestCompaction(HRegion region, HStore store, java.lang.String why, int priority, CompactionLifeCycleTracker tracker, User user) throws java.io.IOException
CompactionRequester
requestCompaction
in interface CompactionRequester
java.io.IOException
public void requestSystemCompaction(HRegion region, java.lang.String why) throws java.io.IOException
java.io.IOException
public void requestSystemCompaction(HRegion region, HStore store, java.lang.String why) throws java.io.IOException
java.io.IOException
public int getCompactionQueueSize()
public int getLargeCompactionQueueSize()
public int getSmallCompactionQueueSize()
public int getSplitQueueSize()
public int getRegionSplitLimit()
public void onConfigurationChange(Configuration newConf)
ConfigurationManager
object when the Configuration
object is reloaded from disk.onConfigurationChange
in interface ConfigurationObserver
protected int getSmallCompactionThreadNum()
protected int getLargeCompactionThreadNum()
protected int getSplitThreadNum()
public void registerChildren(ConfigurationManager manager)
registerChildren
in interface PropagatingConfigurationObserver
manager
- : to register topublic void deregisterChildren(ConfigurationManager manager)
deregisterChildren
in interface PropagatingConfigurationObserver
manager
- : to deregister frompublic ThroughputController getCompactionThroughputController()
public void clearLongCompactionsQueue()
public void clearShortCompactionsQueue()