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	fetchNamespaceQuotaState()
private void	fetchTableQuotaState()
private void	fetchUserQuotaState()

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

cancel, cancel, choreForTesting, cleanup, getInitialDelay, getName, getPeriod, getStopper, getTimeUnit, initialChore, isInitialChoreComplete, isScheduled, run, 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()

fetch

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