@InterfaceAudience.Private public class GeneralBulkAssigner extends BulkAssigner
GeneralBulkAssigner.SingleServerBulkAssigner.| Modifier and Type | Class and Description |
|---|---|
(package private) static class |
GeneralBulkAssigner.SingleServerBulkAssigner
Manage bulk assigning to a server.
|
| Modifier and Type | Field and Description |
|---|---|
(package private) AssignmentManager |
assignmentManager |
(package private) Map<ServerName,List<HRegionInfo>> |
bulkPlan |
private Map<ServerName,List<HRegionInfo>> |
failedPlans |
private static org.apache.commons.logging.Log |
LOG |
private ExecutorService |
pool |
(package private) boolean |
waitTillAllAssigned |
server| Constructor and Description |
|---|
GeneralBulkAssigner(Server server,
Map<ServerName,List<HRegionInfo>> bulkPlan,
AssignmentManager am,
boolean waitTillAllAssigned) |
| Modifier and Type | Method and Description |
|---|---|
protected String |
getThreadNamePrefix() |
protected long |
getTimeoutOnRIT() |
protected Thread.UncaughtExceptionHandler |
getUncaughtExceptionHandler() |
protected void |
populatePool(ExecutorService pool) |
private int |
reassignFailedPlans() |
protected boolean |
waitUntilDone(long timeout)
Wait until bulk assign is done.
|
bulkAssign, bulkAssign, getThreadCountprivate static final org.apache.commons.logging.Log LOG
private Map<ServerName,List<HRegionInfo>> failedPlans
private ExecutorService pool
final Map<ServerName,List<HRegionInfo>> bulkPlan
final AssignmentManager assignmentManager
final boolean waitTillAllAssigned
public GeneralBulkAssigner(Server server, Map<ServerName,List<HRegionInfo>> bulkPlan, AssignmentManager am, boolean waitTillAllAssigned)
protected String getThreadNamePrefix()
getThreadNamePrefix in class BulkAssignerprotected void populatePool(ExecutorService pool)
populatePool in class BulkAssignerprotected boolean waitUntilDone(long timeout)
throws InterruptedException
BulkAssignerwaitUntilDone in class BulkAssignertimeout - How long to wait.InterruptedExceptionprotected long getTimeoutOnRIT()
getTimeoutOnRIT in class BulkAssignerprotected Thread.UncaughtExceptionHandler getUncaughtExceptionHandler()
getUncaughtExceptionHandler in class BulkAssignerprivate int reassignFailedPlans()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.