org.apache.hadoop.hbase.client

Class SimpleRequestController.RequestRowsChecker

java.lang.Object

org.apache.hadoop.hbase.client.SimpleRequestController.RequestRowsChecker

All Implemented Interfaces:

SimpleRequestController.RowChecker

Enclosing class:

SimpleRequestController

static class SimpleRequestController.RequestRowsChecker
extends Object
implements SimpleRequestController.RowChecker

limit the number of rows for each request.

Field Summary

Fields

Modifier and Type	Field and Description
private long	maxRowsPerRequest
private Map<ServerName,Long>	serverRows

Constructor Summary

Constructors

Constructor and Description
RequestRowsChecker(long maxRowsPerRequest)

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

maxRowsPerRequest

private final long maxRowsPerRequest

serverRows

private final Map<ServerName,Long> serverRows

Constructor Detail

RequestRowsChecker

RequestRowsChecker(long maxRowsPerRequest)

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