Package org.apache.hadoop.hbase.regionserver

Class TestScannerLeaseCount.MockedRpcQuotaManager

java.lang.Object

org.apache.hadoop.hbase.quotas.RegionServerRpcQuotaManager

org.apache.hadoop.hbase.regionserver.TestScannerLeaseCount.MockedRpcQuotaManager

All Implemented Interfaces:

org.apache.hadoop.hbase.quotas.RpcQuotaManager

Enclosing class:

TestScannerLeaseCount

private static class TestScannerLeaseCount.MockedRpcQuotaManager
extends org.apache.hadoop.hbase.quotas.RegionServerRpcQuotaManager

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.apache.hadoop.hbase.quotas.RpcThrottlingException	EX

Constructor Summary

Constructors

Constructor	Description
MockedRpcQuotaManager(org.apache.hadoop.hbase.regionserver.RegionServerServices rsServices)

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.hbase.quotas.OperationQuota	checkBatchQuota(org.apache.hadoop.hbase.regionserver.Region region, int numWrites, int numReads)
org.apache.hadoop.hbase.quotas.OperationQuota	checkBatchQuota(org.apache.hadoop.hbase.regionserver.Region region, List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Action> actions, boolean hasCondition)
org.apache.hadoop.hbase.quotas.OperationQuota	checkBatchQuota(org.apache.hadoop.hbase.regionserver.Region region, org.apache.hadoop.hbase.quotas.OperationQuota.OperationType type)
org.apache.hadoop.hbase.quotas.OperationQuota	checkScanQuota(org.apache.hadoop.hbase.regionserver.Region region, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest scanRequest, long maxScannerResultSize, long maxBlockBytesScanned, long prevBlockBytesScannedDifference)

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

getQuota, isRpcThrottleEnabled, start, stop, switchRpcThrottle

Methods inherited from class java.lang.Object

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

Field Details

EX

private static final org.apache.hadoop.hbase.quotas.RpcThrottlingException EX

Constructor Details

MockedRpcQuotaManager

public MockedRpcQuotaManager(org.apache.hadoop.hbase.regionserver.RegionServerServices rsServices)

Method Details

checkScanQuota

public org.apache.hadoop.hbase.quotas.OperationQuota checkScanQuota(org.apache.hadoop.hbase.regionserver.Region region,
 org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest scanRequest,
 long maxScannerResultSize,
 long maxBlockBytesScanned,
 long prevBlockBytesScannedDifference)
                                                             throws IOException,
org.apache.hadoop.hbase.quotas.RpcThrottlingException

Specified by:

checkScanQuota in interface org.apache.hadoop.hbase.quotas.RpcQuotaManager

Overrides:

checkScanQuota in class org.apache.hadoop.hbase.quotas.RegionServerRpcQuotaManager

Throws:

IOException

org.apache.hadoop.hbase.quotas.RpcThrottlingException

checkBatchQuota

public org.apache.hadoop.hbase.quotas.OperationQuota checkBatchQuota(org.apache.hadoop.hbase.regionserver.Region region,
 org.apache.hadoop.hbase.quotas.OperationQuota.OperationType type)
                                                              throws IOException,
org.apache.hadoop.hbase.quotas.RpcThrottlingException

Specified by:

checkBatchQuota in interface org.apache.hadoop.hbase.quotas.RpcQuotaManager

Overrides:

checkBatchQuota in class org.apache.hadoop.hbase.quotas.RegionServerRpcQuotaManager

Throws:

IOException

org.apache.hadoop.hbase.quotas.RpcThrottlingException

checkBatchQuota

public org.apache.hadoop.hbase.quotas.OperationQuota checkBatchQuota(org.apache.hadoop.hbase.regionserver.Region region,
 List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Action> actions,
 boolean hasCondition)
                                                              throws IOException,
org.apache.hadoop.hbase.quotas.RpcThrottlingException

Specified by:

checkBatchQuota in interface org.apache.hadoop.hbase.quotas.RpcQuotaManager

Overrides:

checkBatchQuota in class org.apache.hadoop.hbase.quotas.RegionServerRpcQuotaManager

Throws:

IOException

org.apache.hadoop.hbase.quotas.RpcThrottlingException

checkBatchQuota

public org.apache.hadoop.hbase.quotas.OperationQuota checkBatchQuota(org.apache.hadoop.hbase.regionserver.Region region,
 int numWrites,
 int numReads)
                                                              throws IOException,
org.apache.hadoop.hbase.quotas.RpcThrottlingException

Specified by:

checkBatchQuota in interface org.apache.hadoop.hbase.quotas.RpcQuotaManager

Overrides:

checkBatchQuota in class org.apache.hadoop.hbase.quotas.RegionServerRpcQuotaManager

Throws:

IOException

org.apache.hadoop.hbase.quotas.RpcThrottlingException