org.apache.hadoop.hbase.client

Class SimpleRequestController.TaskCountChecker

java.lang.Object

org.apache.hadoop.hbase.client.SimpleRequestController.TaskCountChecker

All Implemented Interfaces:

SimpleRequestController.RowChecker

Enclosing class:

SimpleRequestController

static class SimpleRequestController.TaskCountChecker
extends Object
implements SimpleRequestController.RowChecker

limit the max number of tasks in an AsyncProcess.

Field Summary

Fields

Modifier and Type	Field and Description
private Set<byte[]>	busyRegions
private static long	MAX_WAITING_TIME
private int	maxConcurrentTasksPerRegion
private int	maxConcurrentTasksPerServer
private int	maxTotalConcurrentTasks
private Set<HRegionInfo>	regionsIncluded
private Set<ServerName>	serversIncluded
private Map<byte[],AtomicInteger>	taskCounterPerRegion
private Map<ServerName,AtomicInteger>	taskCounterPerServer
private AtomicLong	tasksInProgress

Constructor Summary

Constructors

Constructor and Description
TaskCountChecker(int maxTotalConcurrentTasks, int maxConcurrentTasksPerServer, int maxConcurrentTasksPerRegion, AtomicLong tasksInProgress, Map<ServerName,AtomicInteger> taskCounterPerServer, Map<byte[],AtomicInteger> taskCounterPerRegion)

Method Summary

Modifier and Type	Method and Description
RequestController.ReturnCode	canTakeOperation(HRegionLocation loc, long heapSizeOfRow) 1) check the regions is allowed.
void	notifyFinal(RequestController.ReturnCode code, HRegionLocation loc, long heapSizeOfRow) Add the final ReturnCode to the checker.
void	reset() Reset the inner state.
private void	waitForRegion()

Methods inherited from class java.lang.Object

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

Field Detail

MAX_WAITING_TIME

private static final long MAX_WAITING_TIME

See Also:

Constant Field Values

regionsIncluded

private final Set<HRegionInfo> regionsIncluded

serversIncluded

private final Set<ServerName> serversIncluded

maxConcurrentTasksPerRegion

private final int maxConcurrentTasksPerRegion

maxTotalConcurrentTasks

private final int maxTotalConcurrentTasks

maxConcurrentTasksPerServer

private final int maxConcurrentTasksPerServer

taskCounterPerRegion

private final Map<byte[],AtomicInteger> taskCounterPerRegion

taskCounterPerServer

private final Map<ServerName,AtomicInteger> taskCounterPerServer

busyRegions

private final Set<byte[]> busyRegions

tasksInProgress

private final AtomicLong tasksInProgress

Constructor Detail

TaskCountChecker

TaskCountChecker(int maxTotalConcurrentTasks,
                 int maxConcurrentTasksPerServer,
                 int maxConcurrentTasksPerRegion,
                 AtomicLong tasksInProgress,
                 Map<ServerName,AtomicInteger> taskCounterPerServer,
                 Map<byte[],AtomicInteger> taskCounterPerRegion)

Method Detail

reset

public void reset()
           throws InterruptedIOException

Description copied from interface: SimpleRequestController.RowChecker

Reset the inner state.

Specified by:

reset in interface SimpleRequestController.RowChecker

Throws:

InterruptedIOException

waitForRegion

private void waitForRegion()
                    throws InterruptedIOException

Throws:

InterruptedIOException

canTakeOperation

public RequestController.ReturnCode canTakeOperation(HRegionLocation loc,
                                                     long heapSizeOfRow)

1) check the regions is allowed. 2) check the concurrent tasks for regions. 3) check the total concurrent tasks. 4) check the concurrent tasks for server.

Specified by:

canTakeOperation in interface SimpleRequestController.RowChecker

Parameters:

loc - the destination of data

heapSizeOfRow - the data size

Returns:

either Include RequestController.ReturnCode or skip RequestController.ReturnCode

notifyFinal

public void notifyFinal(RequestController.ReturnCode code,
                        HRegionLocation loc,
                        long heapSizeOfRow)

Description copied from interface: SimpleRequestController.RowChecker

Add the final ReturnCode to the checker. The ReturnCode may be reversed, so the checker need the final decision to update the inner state.

Specified by:

notifyFinal in interface SimpleRequestController.RowChecker

Parameters:

code - The final decision

loc - the destination of data

heapSizeOfRow - the data size