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 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 void	fetchExceedThrottleQuota()
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

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

fetchExceedThrottleQuota

private void fetchExceedThrottleQuota()

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)