@InterfaceAudience.Private public class GeneralBulkAssigner extends BulkAssigner
GeneralBulkAssigner.SingleServerBulkAssigner
.server
Modifier and Type | Method and Description |
---|---|
protected String |
getThreadNamePrefix() |
protected long |
getTimeoutOnRIT() |
protected Thread.UncaughtExceptionHandler |
getUncaughtExceptionHandler() |
protected void |
populatePool(ExecutorService pool) |
protected boolean |
waitUntilDone(long timeout)
Wait until bulk assign is done.
|
bulkAssign, bulkAssign, getThreadCount
protected String getThreadNamePrefix()
getThreadNamePrefix
in class BulkAssigner
protected void populatePool(ExecutorService pool)
populatePool
in class BulkAssigner
protected boolean waitUntilDone(long timeout) throws InterruptedException
BulkAssigner
waitUntilDone
in class BulkAssigner
timeout
- How long to wait.InterruptedException
protected long getTimeoutOnRIT()
getTimeoutOnRIT
in class BulkAssigner
protected Thread.UncaughtExceptionHandler getUncaughtExceptionHandler()
getUncaughtExceptionHandler
in class BulkAssigner
Copyright © 2013 The Apache Software Foundation. All rights reserved.