@InterfaceAudience.Private public class BulkReOpen extends BulkAssigner
| Modifier and Type | Field and Description |
|---|---|
private AssignmentManager |
assignmentManager |
private static org.apache.commons.logging.Log |
LOG |
private Map<ServerName,List<HRegionInfo>> |
rsToRegions |
server| Constructor and Description |
|---|
BulkReOpen(Server server,
Map<ServerName,List<HRegionInfo>> serverToRegions,
AssignmentManager am) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
bulkReOpen() |
protected int |
getThreadCount()
Configuration knobs "hbase.bulk.reopen.threadpool.size" number of regions
that can be reopened concurrently.
|
protected void |
populatePool(ExecutorService pool)
Unassign all regions, so that they go through the regular region
assignment flow (in assignment manager) and are re-opened.
|
private void |
unassign(List<HRegionInfo> regions)
Unassign the list of regions.
|
protected boolean |
waitUntilDone(long timeout)
Reopen the regions asynchronously, so always returns true immediately.
|
bulkAssign, bulkAssign, getThreadNamePrefix, getTimeoutOnRIT, getUncaughtExceptionHandlerprivate final Map<ServerName,List<HRegionInfo>> rsToRegions
private final AssignmentManager assignmentManager
private static final org.apache.commons.logging.Log LOG
public BulkReOpen(Server server, Map<ServerName,List<HRegionInfo>> serverToRegions, AssignmentManager am)
protected void populatePool(ExecutorService pool)
populatePool in class BulkAssignerprotected boolean waitUntilDone(long timeout)
waitUntilDone in class BulkAssignertimeout - How long to wait.protected int getThreadCount()
getThreadCount in class BulkAssignerpublic boolean bulkReOpen()
throws InterruptedException,
IOException
InterruptedExceptionIOExceptionprivate void unassign(List<HRegionInfo> regions) throws InterruptedException
regions - InterruptedExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.