org.apache.hadoop.hbase.quotas

Class RegionServerRpcQuotaManager

java.lang.Object

org.apache.hadoop.hbase.quotas.RegionServerRpcQuotaManager

@InterfaceAudience.Private
 @InterfaceStability.Evolving
public class RegionServerRpcQuotaManager
extends Object

Region Server Quota Manager. It is responsible to provide access to the quota information of each user/table. The direct user of this class is the RegionServer that will get and check the user/table quota for each operation (put, get, scan). For system tables and user/table with a quota specified, the quota check will be a noop.

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG
private QuotaCache	quotaCache
private boolean	rpcThrottleEnabled
private RpcThrottleStorage	rpcThrottleStorage
private RegionServerServices	rsServices

Constructor Summary

Constructors

Constructor and Description
RegionServerRpcQuotaManager(RegionServerServices rsServices)

Method Summary

Modifier and Type	Method and Description
private OperationQuota	checkQuota(Region region, int numWrites, int numReads, int numScans) Check the quota for the current (rpc-context) user.
OperationQuota	checkQuota(Region region, List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Action> actions) Check the quota for the current (rpc-context) user.
OperationQuota	checkQuota(Region region, OperationQuota.OperationType type) Check the quota for the current (rpc-context) user.
OperationQuota	getQuota(org.apache.hadoop.security.UserGroupInformation ugi, TableName table) Returns the quota for an operation.
(package private) QuotaCache	getQuotaCache()
private boolean	isQuotaEnabled()
protected boolean	isRpcThrottleEnabled()
void	start(RpcScheduler rpcScheduler)
void	stop()
void	switchRpcThrottle(boolean enable)

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

rsServices

private final RegionServerServices rsServices

quotaCache

private QuotaCache quotaCache

rpcThrottleEnabled

private volatile boolean rpcThrottleEnabled

rpcThrottleStorage

private RpcThrottleStorage rpcThrottleStorage

Constructor Detail

RegionServerRpcQuotaManager

public RegionServerRpcQuotaManager(RegionServerServices rsServices)

Method Detail

start

public void start(RpcScheduler rpcScheduler)
           throws IOException

Throws:

IOException

stop

public void stop()

isRpcThrottleEnabled

protected boolean isRpcThrottleEnabled()

isQuotaEnabled

private boolean isQuotaEnabled()

switchRpcThrottle

public void switchRpcThrottle(boolean enable)
                       throws IOException

Throws:

IOException

getQuotaCache

QuotaCache getQuotaCache()

getQuota

public OperationQuota getQuota(org.apache.hadoop.security.UserGroupInformation ugi,
                               TableName table)

Returns the quota for an operation.

Parameters:

ugi - the user that is executing the operation

table - the table where the operation will be executed

Returns:

the OperationQuota

checkQuota

public OperationQuota checkQuota(Region region,
                                 OperationQuota.OperationType type)
                          throws IOException,
                                 RpcThrottlingException

Check the quota for the current (rpc-context) user. Returns the OperationQuota used to get the available quota and to report the data/usage of the operation.

Parameters:

region - the region where the operation will be performed

type - the operation type

Returns:

the OperationQuota

Throws:

RpcThrottlingException - if the operation cannot be executed due to quota exceeded.

IOException

checkQuota

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

Check the quota for the current (rpc-context) user. Returns the OperationQuota used to get the available quota and to report the data/usage of the operation.

Parameters:

region - the region where the operation will be performed

actions - the "multi" actions to perform

Returns:

the OperationQuota

Throws:

RpcThrottlingException - if the operation cannot be executed due to quota exceeded.

IOException

checkQuota

private OperationQuota checkQuota(Region region,
                                  int numWrites,
                                  int numReads,
                                  int numScans)
                           throws IOException,
                                  RpcThrottlingException

Check the quota for the current (rpc-context) user. Returns the OperationQuota used to get the available quota and to report the data/usage of the operation.

Parameters:

region - the region where the operation will be performed

numWrites - number of writes to perform

numReads - number of short-reads to perform

numScans - number of scan to perform

Returns:

the OperationQuota

Throws:

RpcThrottlingException - if the operation cannot be executed due to quota exceeded.

IOException