org.apache.hadoop.hbase.quotas

Class UserQuotaState

java.lang.Object

org.apache.hadoop.hbase.quotas.QuotaState

org.apache.hadoop.hbase.quotas.UserQuotaState

@InterfaceAudience.Private
 @InterfaceStability.Evolving
public class UserQuotaState
extends QuotaState

In-Memory state of the user quotas

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	bypassGlobals
private Map<String,QuotaLimiter>	namespaceLimiters
private Map<TableName,QuotaLimiter>	tableLimiters

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

globalLimiter, lastQuery, lastUpdate

Constructor Summary

Constructors

Constructor and Description
UserQuotaState()
UserQuotaState(long updateTs)

Method Summary

Modifier and Type	Method and Description
QuotaLimiter	getTableLimiter(TableName table) Return the limiter for the specified table associated with this quota.
boolean	hasBypassGlobals()
boolean	isBypass()
private <K> Map<K,QuotaLimiter>	setLimiter(Map<K,QuotaLimiter> limiters, K key, org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas quotas)
void	setQuotas(org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas quotas) Setup the global quota information.
void	setQuotas(String namespace, org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas quotas) Add the quota information of the specified namespace.
void	setQuotas(TableName table, org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas quotas) Add the quota information of the specified table.
String	toString()
void	update(QuotaState other) Perform an update of the quota state based on the other quota state object.
private static <K> Map<K,QuotaLimiter>	updateLimiters(Map<K,QuotaLimiter> map, Map<K,QuotaLimiter> otherMap)

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

getGlobalLimiter, getGlobalLimiterWithoutUpdatingLastQuery, getLastQuery, getLastUpdate

Methods inherited from class java.lang.Object

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

Field Detail

namespaceLimiters

private Map<String,QuotaLimiter> namespaceLimiters

tableLimiters

private Map<TableName,QuotaLimiter> tableLimiters

bypassGlobals

private boolean bypassGlobals

Constructor Detail

UserQuotaState

public UserQuotaState()

UserQuotaState

public UserQuotaState(long updateTs)

Method Detail

toString

public String toString()

Overrides:

toString in class QuotaState

isBypass

public boolean isBypass()

Overrides:

isBypass in class QuotaState

Returns:

true if there is no quota information associated to this object

hasBypassGlobals

public boolean hasBypassGlobals()

setQuotas

public void setQuotas(org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas quotas)

Description copied from class: QuotaState

Setup the global quota information. (This operation is part of the QuotaState setup)

Overrides:

setQuotas in class QuotaState

setQuotas

public void setQuotas(TableName table,
                      org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas quotas)

Add the quota information of the specified table. (This operation is part of the QuotaState setup)

setQuotas

public void setQuotas(String namespace,
                      org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas quotas)

Add the quota information of the specified namespace. (This operation is part of the QuotaState setup)

setLimiter

private <K> Map<K,QuotaLimiter> setLimiter(Map<K,QuotaLimiter> limiters,
                                           K key,
                                           org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas quotas)

update

public void update(QuotaState other)

Perform an update of the quota state based on the other quota state object. (This operation is executed by the QuotaCache)

Overrides:

update in class QuotaState

updateLimiters

private static <K> Map<K,QuotaLimiter> updateLimiters(Map<K,QuotaLimiter> map,
                                                      Map<K,QuotaLimiter> otherMap)

getTableLimiter

public QuotaLimiter getTableLimiter(TableName table)

Return the limiter for the specified table associated with this quota. If the table does not have its own quota limiter the global one will be returned. In case there is no quota limiter associated with this object a noop limiter will be returned.

Returns:

the quota limiter for the specified table