Package 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	Description
private final Set<byte[]>	busyRegions
private static final long	MAX_WAITING_TIME
private final int	maxConcurrentTasksPerRegion
private final int	maxConcurrentTasksPerServer
private final int	maxTotalConcurrentTasks
private final Set<HRegionInfo>	regionsIncluded
private final Set<ServerName>	serversIncluded
private final Map<byte[],AtomicInteger>	taskCounterPerRegion
private final Map<ServerName,AtomicInteger>	taskCounterPerServer
private final AtomicLong	tasksInProgress

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 Details

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 Details

TaskCountChecker

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

Method Details

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