org.apache.hadoop.hbase.master

Class BulkAssigner

java.lang.Object

org.apache.hadoop.hbase.master.BulkAssigner

Direct Known Subclasses:

BulkReOpen, GeneralBulkAssigner

@InterfaceAudience.Private
public abstract class BulkAssigner
extends java.lang.Object

Base class used bulk assigning and unassigning regions. Encapsulates a fixed size thread pool of executors to run assignment/unassignment. Implement populatePool(java.util.concurrent.ExecutorService) and waitUntilDone(long). The default implementation of the getUncaughtExceptionHandler() is to abort the hosting Server.

Field Summary

Fields

Modifier and Type	Field and Description
protected Server	server

Constructor Summary

Constructors

Constructor and Description
BulkAssigner(Server server)

Method Summary

Modifier and Type	Method and Description
boolean	bulkAssign()
boolean	bulkAssign(boolean sync) Run the bulk assign.
protected int	getThreadCount()
protected java.lang.String	getThreadNamePrefix()
protected long	getTimeoutOnRIT()
protected java.lang.Thread.UncaughtExceptionHandler	getUncaughtExceptionHandler()
protected abstract void	populatePool(java.util.concurrent.ExecutorService pool)
protected abstract boolean	waitUntilDone(long timeout) Wait until bulk assign is done.

Methods inherited from class java.lang.Object

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

Field Detail

server

protected final Server server

Constructor Detail

BulkAssigner

public BulkAssigner(Server server)

Parameters:

server - An instance of Server

Method Detail

getThreadNamePrefix

protected java.lang.String getThreadNamePrefix()

Returns:

What to use for a thread prefix when executor runs.

getUncaughtExceptionHandler

protected java.lang.Thread.UncaughtExceptionHandler getUncaughtExceptionHandler()

getThreadCount

protected int getThreadCount()

getTimeoutOnRIT

protected long getTimeoutOnRIT()

populatePool

protected abstract void populatePool(java.util.concurrent.ExecutorService pool)
                              throws java.io.IOException

Throws:

java.io.IOException

bulkAssign

public boolean bulkAssign()
                   throws java.lang.InterruptedException,
                          java.io.IOException

Throws:

java.lang.InterruptedException

java.io.IOException

bulkAssign

public boolean bulkAssign(boolean sync)
                   throws java.lang.InterruptedException,
                          java.io.IOException

Run the bulk assign.

Parameters:

sync - Whether to assign synchronously.

Returns:

True if done.

Throws:

java.lang.InterruptedException

java.io.IOException

waitUntilDone

protected abstract boolean waitUntilDone(long timeout)
                                  throws java.lang.InterruptedException

Wait until bulk assign is done.

Parameters:

timeout - How long to wait.

Returns:

True if the condition we were waiting on happened.

Throws:

java.lang.InterruptedException