@InterfaceAudience.Private public class BulkReOpen extends BulkAssigner
server
Constructor and Description |
---|
BulkReOpen(Server server,
java.util.Map<ServerName,java.util.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(java.util.concurrent.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, getUncaughtExceptionHandler
public BulkReOpen(Server server, java.util.Map<ServerName,java.util.List<HRegionInfo>> serverToRegions, AssignmentManager am)
protected void populatePool(java.util.concurrent.ExecutorService pool)
populatePool
in class BulkAssigner
protected boolean waitUntilDone(long timeout)
waitUntilDone
in class BulkAssigner
timeout
- How long to wait.protected int getThreadCount()
getThreadCount
in class BulkAssigner
public boolean bulkReOpen() throws java.lang.InterruptedException, java.io.IOException
java.lang.InterruptedException
java.io.IOException