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 and Description
private long	maxHeapSizePerRequest
private Map<ServerName,Long>	serverRequestSizes

Constructor Summary

Constructors

Constructor and Description
RequestHeapSizeChecker(long maxHeapSizePerRequest)

Method Summary

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

maxHeapSizePerRequest

private final long maxHeapSizePerRequest

serverRequestSizes

private final Map<ServerName,Long> serverRequestSizes

Constructor Detail

RequestHeapSizeChecker

RequestHeapSizeChecker(long maxHeapSizePerRequest)

Method Detail

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