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 and Description
private long	heapSize
private long	maxHeapSizeSubmit

Constructor Summary

Constructors

Constructor and Description
SubmittedSizeChecker(long maxHeapSizeSubmit)

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

maxHeapSizeSubmit

private final long maxHeapSizeSubmit

heapSize

private long heapSize

Constructor Detail

SubmittedSizeChecker

SubmittedSizeChecker(long maxHeapSizeSubmit)

Method Detail

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