Package 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	Description
private long	lastUpdate
private final QuotaCache.RefreshableExpiringValueCache<Integer>	regionServersSize
private final QuotaCache.RefreshableExpiringValueCache<ClusterMetrics>	tableRegionStatesClusterMetrics

Constructor Summary

Constructors

Constructor	Description
QuotaRefresherChore(org.apache.hadoop.conf.Configuration conf, int period, Stoppable stoppable)

Method Summary

Modifier and Type	Method	Description
protected void	chore()	The task to execute on each scheduled execution of the Chore
private <K, V extends QuotaState> void	fetch(String type, ConcurrentMap<K,V> quotasMap, QuotaCache.Fetcher<K,V> fetcher)
private void	fetchExceedThrottleQuota()
private void	fetchNamespaceQuotaState()
private void	fetchRegionServerQuotaState()
private void	fetchTableQuotaState()
private void	fetchUserQuotaState()
boolean	triggerNow()	Returns false when the Chore is not currently scheduled with a ChoreService
private void	updateMachineQuotaFactors(int rsSize)
private void	updateOnlyMachineQuotaFactors()	This method is cheaper than updateTableMachineQuotaFactors() and should be used if we don't have any table quotas in the cache.
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.
private void	updateTableMachineQuotaFactors()	This will call updateMachineQuotaFactors(int), and then update the table machine factors as well.

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

Methods inherited from class java.lang.Object

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

Field Details

lastUpdate

private long lastUpdate

tableRegionStatesClusterMetrics

private final QuotaCache.RefreshableExpiringValueCache<ClusterMetrics> tableRegionStatesClusterMetrics

regionServersSize

private final QuotaCache.RefreshableExpiringValueCache<Integer> regionServersSize

Constructor Details

QuotaRefresherChore

public QuotaRefresherChore(org.apache.hadoop.conf.Configuration conf,
 int period,
 Stoppable stoppable)

Method Details

triggerNow

public boolean triggerNow()

Description copied from class: ScheduledChore

Returns false when the Chore is not currently scheduled with a ChoreService

Overrides:

triggerNow in class ScheduledChore

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,
 ConcurrentMap<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.

updateOnlyMachineQuotaFactors

private void updateOnlyMachineQuotaFactors()

This method is cheaper than updateTableMachineQuotaFactors() and should be used if we don't have any table quotas in the cache.

updateTableMachineQuotaFactors

private void updateTableMachineQuotaFactors()

This will call updateMachineQuotaFactors(int), and then update the table machine factors as well. This relies on a more expensive query for ClusterMetrics.

updateMachineQuotaFactors

private void updateMachineQuotaFactors(int rsSize)