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.

Constructor Summary

Constructors

Constructor and Description
RegionServerRpcQuotaManager(RegionServerServices rsServices)

Method Summary

Modifier and Type	Method and Description
OperationQuota	checkQuota(Region region, List<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.
boolean	isQuotaEnabled()
void	start(RpcScheduler rpcScheduler)
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

RegionServerRpcQuotaManager

public RegionServerRpcQuotaManager(RegionServerServices rsServices)

Method Detail

start

public void start(RpcScheduler rpcScheduler)
           throws IOException

Throws:

IOException

stop

public void stop()

isQuotaEnabled

public boolean isQuotaEnabled()

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<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