@InterfaceAudience.Private public class GeneralBulkAssigner extends BulkAssigner
GeneralBulkAssigner.SingleServerBulkAssigner
.server
Constructor and Description |
---|
GeneralBulkAssigner(Server server,
java.util.Map<ServerName,java.util.List<HRegionInfo>> bulkPlan,
AssignmentManager am,
boolean waitTillAllAssigned) |
Modifier and Type | Method and Description |
---|---|
protected java.lang.String |
getThreadNamePrefix() |
protected long |
getTimeoutOnRIT() |
protected java.lang.Thread.UncaughtExceptionHandler |
getUncaughtExceptionHandler() |
protected void |
populatePool(java.util.concurrent.ExecutorService pool) |
protected boolean |
waitUntilDone(long timeout)
Wait until bulk assign is done.
|
bulkAssign, bulkAssign, getThreadCount
public GeneralBulkAssigner(Server server, java.util.Map<ServerName,java.util.List<HRegionInfo>> bulkPlan, AssignmentManager am, boolean waitTillAllAssigned)
protected java.lang.String getThreadNamePrefix()
getThreadNamePrefix
in class BulkAssigner
protected void populatePool(java.util.concurrent.ExecutorService pool)
populatePool
in class BulkAssigner
protected boolean waitUntilDone(long timeout) throws java.lang.InterruptedException
BulkAssigner
waitUntilDone
in class BulkAssigner
timeout
- How long to wait.java.lang.InterruptedException
protected long getTimeoutOnRIT()
getTimeoutOnRIT
in class BulkAssigner
protected java.lang.Thread.UncaughtExceptionHandler getUncaughtExceptionHandler()
getUncaughtExceptionHandler
in class BulkAssigner