Package org.apache.hadoop.hbase.client

Class SimpleRequestController.RequestHeapSizeChecker

java.lang.Object

org.apache.hadoop.hbase.client.SimpleRequestController.RequestHeapSizeChecker

All Implemented Interfaces:

SimpleRequestController.RowChecker

Enclosing class:

SimpleRequestController

static class SimpleRequestController.RequestHeapSizeChecker
extends Object
implements SimpleRequestController.RowChecker

limit the heap size for each request.

Field Summary

Fields

Modifier and Type	Field	Description
private final long	maxHeapSizePerRequest
private final Map<ServerName,Long>	serverRequestSizes

Constructor Summary

Constructors

Constructor	Description
RequestHeapSizeChecker(long maxHeapSizePerRequest)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

maxHeapSizePerRequest

private final long maxHeapSizePerRequest

serverRequestSizes

private final Map<ServerName,Long> serverRequestSizes

Constructor Details

RequestHeapSizeChecker

RequestHeapSizeChecker(long maxHeapSizePerRequest)

Method Details

reset

public void reset()

Description copied from interface: SimpleRequestController.RowChecker

Reset the inner state.

Specified by:

reset in interface SimpleRequestController.RowChecker

canTakeOperation

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

Specified by:

canTakeOperation in interface SimpleRequestController.RowChecker

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