@InterfaceAudience.Private public class BulkReOpen extends BulkAssigner
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.
|
protected boolean |
waitUntilDone(long timeout)
Reopen the regions asynchronously, so always returns true immediately.
|
bulkAssign, bulkAssign, getThreadNamePrefix, getTimeoutOnRIT, getUncaughtExceptionHandlerpublic 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
InterruptedExceptionIOExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.