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

@InterfaceAudience.Private
 @InterfaceStability.Evolving
public class ExceedOperationQuota
extends DefaultOperationQuota

Nested Class Summary

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

OperationQuota.OperationType

Field Summary

Fields

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

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

limiters, readAvailable, readCapacityUnitConsumed, readCapacityUnitDiff, readConsumed, readDiff, writeAvailable, writeCapacityUnitConsumed, writeCapacityUnitDiff, writeConsumed, writeDiff

Constructor Summary

Constructors

Constructor and Description
ExceedOperationQuota(org.apache.hadoop.conf.Configuration conf, QuotaLimiter regionServerLimiter, QuotaLimiter... limiters)

Method Summary

Modifier and Type	Method and Description
void	checkQuota(int numWrites, int numReads, int numScans) Checks if it is possible to execute the specified operation.
void	close() Cleanup method on operation completion

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

addGetResult, addMutation, addScanResult, getReadAvailable, getWriteAvailable, updateEstimateConsumeQuota

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

regionServerLimiter

private QuotaLimiter regionServerLimiter

Constructor Detail

ExceedOperationQuota

public ExceedOperationQuota(org.apache.hadoop.conf.Configuration conf,
                            QuotaLimiter regionServerLimiter,
                            QuotaLimiter... limiters)

Method Detail

checkQuota

public void checkQuota(int numWrites,
                       int numReads,
                       int numScans)
                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:

checkQuota in interface OperationQuota

Overrides:

checkQuota in class DefaultOperationQuota

Parameters:

numWrites - number of write operation that will be performed

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

numScans - number of long-read operation that will be performed

Throws:

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

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