Package org.apache.hadoop.hbase.client

Class SimpleRequestController.SubmittedSizeChecker

java.lang.Object

org.apache.hadoop.hbase.client.SimpleRequestController.SubmittedSizeChecker

All Implemented Interfaces:

SimpleRequestController.RowChecker

Enclosing class:

SimpleRequestController

static class SimpleRequestController.SubmittedSizeChecker
extends Object
implements SimpleRequestController.RowChecker

limit the heapsize of total submitted data. Reduce the limit of heapsize for submitting quickly if there is no running task.

Field Summary

Fields

Modifier and Type	Field	Description
private long	heapSize
private final long	maxHeapSizeSubmit

Constructor Summary

Constructors

Constructor	Description
SubmittedSizeChecker(long maxHeapSizeSubmit)

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

maxHeapSizeSubmit

private final long maxHeapSizeSubmit

heapSize

private long heapSize

Constructor Details

SubmittedSizeChecker

SubmittedSizeChecker(long maxHeapSizeSubmit)

Method Details

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

reset

public void reset()

Description copied from interface: SimpleRequestController.RowChecker

Reset the inner state.

Specified by:

reset in interface SimpleRequestController.RowChecker