org.apache.hadoop.hbase.quotas

Class QuotaCache.QuotaRefresherChore

java.lang.Object

org.apache.hadoop.hbase.ScheduledChore

org.apache.hadoop.hbase.quotas.QuotaCache.QuotaRefresherChore

All Implemented Interfaces:

Runnable

Enclosing class:

QuotaCache

private class QuotaCache.QuotaRefresherChore
extends ScheduledChore

Field Summary

Fields

Modifier and Type	Field and Description
private long	lastUpdate

Constructor Summary

Constructors

Constructor and Description
QuotaRefresherChore(int period, Stoppable stoppable)

Method Summary

Modifier and Type	Method and Description
protected void	chore() The task to execute on each scheduled execution of the Chore
private <K,V extends QuotaState> void	fetch(String type, ConcurrentHashMap<K,V> quotasMap, QuotaCache.Fetcher<K,V> fetcher)
private void	fetchExceedThrottleQuota()
private void	fetchNamespaceQuotaState()
private void	fetchRegionServerQuotaState()
private void	fetchTableQuotaState()
private void	fetchUserQuotaState()
private void	updateQuotaFactors() Update quota factors which is used to divide cluster scope quota into machine scope quota For user/namespace/user over namespace quota, use [1 / RSNum] as machine factor.

Methods inherited from class org.apache.hadoop.hbase.ScheduledChore

cancel, cancel, choreForTesting, cleanup, getInitialDelay, getName, getPeriod, getStopper, getTimeUnit, initialChore, isInitialChoreComplete, isScheduled, run, shutdown, shutdown, toString, triggerNow

Methods inherited from class java.lang.Object

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

Field Detail

lastUpdate

private long lastUpdate

Constructor Detail

QuotaRefresherChore

public QuotaRefresherChore(int period,
                           Stoppable stoppable)

Method Detail

chore

protected void chore()

Description copied from class: ScheduledChore

The task to execute on each scheduled execution of the Chore

Specified by:

chore in class ScheduledChore

fetchNamespaceQuotaState

private void fetchNamespaceQuotaState()

fetchTableQuotaState

private void fetchTableQuotaState()

fetchUserQuotaState

private void fetchUserQuotaState()

fetchRegionServerQuotaState

private void fetchRegionServerQuotaState()

fetchExceedThrottleQuota

private void fetchExceedThrottleQuota()

fetch

private <K,V extends QuotaState> void fetch(String type,
                                            ConcurrentHashMap<K,V> quotasMap,
                                            QuotaCache.Fetcher<K,V> fetcher)

updateQuotaFactors

private void updateQuotaFactors()

Update quota factors which is used to divide cluster scope quota into machine scope quota For user/namespace/user over namespace quota, use [1 / RSNum] as machine factor. For table/user over table quota, use [1 / TotalTableRegionNum * MachineTableRegionNum] as machine factor.