org.apache.hadoop.hbase.master

Class GeneralBulkAssigner

java.lang.Object

org.apache.hadoop.hbase.master.BulkAssigner

org.apache.hadoop.hbase.master.GeneralBulkAssigner

@InterfaceAudience.Private
public class GeneralBulkAssigner
extends BulkAssigner

Run bulk assign. Does one RCP per regionserver passing a batch of regions using GeneralBulkAssigner.SingleServerBulkAssigner.

Field Summary

Fields inherited from class org.apache.hadoop.hbase.master.BulkAssigner

server

Constructor Summary

Constructors

Constructor and Description
GeneralBulkAssigner(Server server, Map<ServerName,List<HRegionInfo>> bulkPlan, AssignmentManager am, boolean waitTillAllAssigned)

Method Summary

Methods

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.

Methods inherited from class org.apache.hadoop.hbase.master.BulkAssigner

bulkAssign, bulkAssign, getThreadCount

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GeneralBulkAssigner

public GeneralBulkAssigner(Server server,
                   Map<ServerName,List<HRegionInfo>> bulkPlan,
                   AssignmentManager am,
                   boolean waitTillAllAssigned)

Method Detail

getThreadNamePrefix

protected String getThreadNamePrefix()

Overrides:

getThreadNamePrefix in class BulkAssigner

Returns:

What to use for a thread prefix when executor runs.

populatePool

protected void populatePool(ExecutorService pool)

Specified by:

populatePool in class BulkAssigner

waitUntilDone

protected boolean waitUntilDone(long timeout)
                         throws InterruptedException

Description copied from class: BulkAssigner

Wait until bulk assign is done.

Specified by:

waitUntilDone in class BulkAssigner

Parameters:

timeout - How long to wait.

Returns:

true if done.

Throws:

InterruptedException

getTimeoutOnRIT

protected long getTimeoutOnRIT()

Overrides:

getTimeoutOnRIT in class BulkAssigner

getUncaughtExceptionHandler

protected Thread.UncaughtExceptionHandler getUncaughtExceptionHandler()

Overrides:

getUncaughtExceptionHandler in class BulkAssigner