Package org.apache.hadoop.hbase.quotas

Class ExceedOperationQuota

java.lang.Object

org.apache.hadoop.hbase.quotas.DefaultOperationQuota

org.apache.hadoop.hbase.quotas.ExceedOperationQuota

All Implemented Interfaces:

OperationQuota

@Private
@Evolving
public class ExceedOperationQuota
extends DefaultOperationQuota

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static interface	ExceedOperationQuota.CheckQuotaRunnable

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.quotas.OperationQuota

OperationQuota.OperationType

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private QuotaLimiter	regionServerLimiter

Fields inherited from class org.apache.hadoop.hbase.quotas.DefaultOperationQuota

handlerUsageTimeConsumed, handlerUsageTimeDiff, limiters, readAvailable, readCapacityUnitConsumed, readCapacityUnitDiff, readConsumed, readDiff, writeCapacityUnitConsumed, writeCapacityUnitDiff, writeConsumed, writeDiff

Fields inherited from interface org.apache.hadoop.hbase.quotas.OperationQuota

USE_RESULT_SIZE_BYTES, USE_RESULT_SIZE_BYTES_DEFAULT

Constructor Summary

Constructors

Constructor	Description
ExceedOperationQuota(org.apache.hadoop.conf.Configuration conf, int blockSizeBytes, double requestsPerSecond, QuotaLimiter regionServerLimiter, QuotaLimiter... limiters)

Method Summary

Modifier and Type	Method	Description
void	checkBatchQuota(int numWrites, int numReads, boolean isAtomic)	Checks if it is possible to execute the specified operation.
private void	checkQuota(Runnable estimateQuota, ExceedOperationQuota.CheckQuotaRunnable checkQuota, int numWrites, int numReads, int numScans, boolean isAtomic)
void	checkScanQuota(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest scanRequest, long maxScannerResultSize, long maxBlockBytesScanned, long prevBlockBytesScannedDifference)	Checks if it is possible to execute the scan.
void	close()	Cleanup method on operation completion

Methods inherited from class org.apache.hadoop.hbase.quotas.DefaultOperationQuota

addGetResult, addMutation, addScanResult, addScanResultCells, getReadAvailable, getReadConsumed, getScanReadConsumeEstimate, updateEstimateConsumeBatchQuota, updateEstimateConsumeScanQuota

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.quotas.OperationQuota

getMaxResultSize

Field Details

LOG

private static final org.slf4j.Logger LOG

regionServerLimiter

private QuotaLimiter regionServerLimiter

Constructor Details

ExceedOperationQuota

public ExceedOperationQuota(org.apache.hadoop.conf.Configuration conf,
 int blockSizeBytes,
 double requestsPerSecond,
 QuotaLimiter regionServerLimiter,
 QuotaLimiter... limiters)

Method Details

checkBatchQuota

public void checkBatchQuota(int numWrites,
 int numReads,
 boolean isAtomic)
                     throws RpcThrottlingException

Description copied from interface: OperationQuota

Checks if it is possible to execute the specified operation. The quota will be estimated based on the number of operations to perform and the average size accumulated during time.

Specified by:

checkBatchQuota in interface OperationQuota

Overrides:

checkBatchQuota in class DefaultOperationQuota

Parameters:

numWrites - number of write operation that will be performed

numReads - number of small-read operation that will be performed

Throws:

RpcThrottlingException - if the operation cannot be performed because RPC quota is exceeded.

checkScanQuota

public void checkScanQuota(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest scanRequest,
 long maxScannerResultSize,
 long maxBlockBytesScanned,
 long prevBlockBytesScannedDifference)
                    throws RpcThrottlingException

Description copied from interface: OperationQuota

Checks if it is possible to execute the scan. The quota will be estimated based on the composition of the scan.

Specified by:

checkScanQuota in interface OperationQuota

Overrides:

checkScanQuota in class DefaultOperationQuota

Parameters:

scanRequest - the given scan operation

maxScannerResultSize - the maximum bytes to be returned by the scanner

maxBlockBytesScanned - the maximum bytes scanned in a single RPC call by the scanner

prevBlockBytesScannedDifference - the difference between BBS of the previous two next calls

Throws:

RpcThrottlingException - if the operation cannot be performed because RPC quota is exceeded.

checkQuota

private void checkQuota(Runnable estimateQuota,
 ExceedOperationQuota.CheckQuotaRunnable checkQuota,
 int numWrites,
 int numReads,
 int numScans,
 boolean isAtomic)
                 throws RpcThrottlingException

Throws:

RpcThrottlingException

close

public void close()

Description copied from interface: OperationQuota

Cleanup method on operation completion

Specified by:

close in interface OperationQuota

Overrides:

close in class DefaultOperationQuota