BulkAssigner (Apache HBase 1.2.12 API)

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

java.lang.Object
- org.apache.hadoop.hbase.master.BulkAssigner

Direct Known Subclasses:

BulkReOpen, DisableTableHandler.BulkDisabler, DisableTableProcedure.BulkDisabler, GeneralBulkAssigner
```
@InterfaceAudience.Private
public abstract class BulkAssigner
extends 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

Methods
Modifier and Type	Method and Description
`boolean`	`bulkAssign()`
`boolean`	`bulkAssign(boolean sync)` Run the bulk assign.
`protected int`	`getThreadCount()`
`protected String`	`getThreadNamePrefix()`
`protected long`	`getTimeoutOnRIT()`
`protected Thread.UncaughtExceptionHandler`	`getUncaughtExceptionHandler()`
`protected abstract void`	`populatePool(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 String getThreadNamePrefix()
```
Returns:
What to use for a thread prefix when executor runs.

getUncaughtExceptionHandler

protected Thread.UncaughtExceptionHandler getUncaughtExceptionHandler()

getThreadCount
```
protected int getThreadCount()
```

getTimeoutOnRIT
```
protected long getTimeoutOnRIT()
```

populatePool

protected abstract void populatePool(ExecutorService pool)
                              throws IOException

Throws:: IOException

bulkAssign

public boolean bulkAssign()
                   throws InterruptedException,
                          IOException

Throws:: InterruptedException; IOException

bulkAssign

public boolean bulkAssign(boolean sync)
                   throws InterruptedException,
                          IOException

Run the bulk assign.

Parameters:: sync - Whether to assign synchronously.
Returns:: True if done.
Throws:: InterruptedException; IOException

waitUntilDone
```
protected abstract boolean waitUntilDone(long timeout)
                                  throws InterruptedException
```
Wait until bulk assign is done.

Parameters:
timeout - How long to wait.

Returns:
True if the condition we were waiting on happened.

Throws:

InterruptedException

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.