@InterfaceAudience.Private @InterfaceStability.Evolving public class QuotaCache extends java.lang.Object implements Stoppable
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
REFRESH_CONF_KEY |
Constructor and Description |
---|
QuotaCache(RegionServerServices rsServices) |
Modifier and Type | Method and Description |
---|---|
QuotaLimiter |
getNamespaceLimiter(java.lang.String namespace)
Returns the limiter associated to the specified namespace.
|
QuotaLimiter |
getTableLimiter(TableName table)
Returns the limiter associated to the specified table.
|
QuotaLimiter |
getUserLimiter(UserGroupInformation ugi,
TableName table)
Returns the limiter associated to the specified user/table.
|
UserQuotaState |
getUserQuotaState(UserGroupInformation ugi)
Returns the QuotaState associated to the specified user.
|
boolean |
isStopped() |
static boolean |
isTEST_FORCE_REFRESH() |
static void |
setTEST_FORCE_REFRESH(boolean tEST_FORCE_REFRESH) |
void |
start() |
void |
stop(java.lang.String why)
Stop this service.
|
public static final java.lang.String REFRESH_CONF_KEY
public QuotaCache(RegionServerServices rsServices)
public void start() throws java.io.IOException
java.io.IOException
public void stop(java.lang.String why)
Stoppable
public boolean isStopped()
isStopped
in interface Stoppable
Stoppable.stop(String)
has been closed.public QuotaLimiter getUserLimiter(UserGroupInformation ugi, TableName table)
ugi
- the user to limittable
- the table to limitpublic UserQuotaState getUserQuotaState(UserGroupInformation ugi)
ugi
- the userpublic QuotaLimiter getTableLimiter(TableName table)
table
- the table to limitpublic QuotaLimiter getNamespaceLimiter(java.lang.String namespace)
namespace
- the namespace to limitpublic static boolean isTEST_FORCE_REFRESH()
public static void setTEST_FORCE_REFRESH(boolean tEST_FORCE_REFRESH)