@InterfaceAudience.Private @InterfaceStability.Evolving public class QuotaUtil extends QuotaTableUtil
QuotaTableUtil.NamespaceQuotasVisitor, QuotaTableUtil.QuotasVisitor, QuotaTableUtil.TableQuotasVisitor, QuotaTableUtil.UserQuotasVisitor
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
QUOTA_CONF_KEY |
static HTableDescriptor |
QUOTA_TABLE_DESC
Table descriptor for Quota internal table
|
QUOTA_FAMILY_INFO, QUOTA_FAMILY_USAGE, QUOTA_NAMESPACE_ROW_KEY_PREFIX, QUOTA_POLICY_COLUMN, QUOTA_QUALIFIER_POLICY, QUOTA_QUALIFIER_SETTINGS, QUOTA_QUALIFIER_SETTINGS_PREFIX, QUOTA_TABLE_NAME, QUOTA_TABLE_ROW_KEY_PREFIX, QUOTA_USER_ROW_KEY_PREFIX
Constructor and Description |
---|
QuotaUtil() |
Modifier and Type | Method and Description |
---|---|
static void |
addNamespaceQuota(Connection connection,
java.lang.String namespace,
QuotaProtos.Quotas data) |
static void |
addTableQuota(Connection connection,
TableName table,
QuotaProtos.Quotas data) |
static void |
addUserQuota(Connection connection,
java.lang.String user,
QuotaProtos.Quotas data) |
static void |
addUserQuota(Connection connection,
java.lang.String user,
java.lang.String namespace,
QuotaProtos.Quotas data) |
static void |
addUserQuota(Connection connection,
java.lang.String user,
TableName table,
QuotaProtos.Quotas data) |
static long |
calculateMutationSize(Mutation mutation) |
static long |
calculateResultSize(java.util.List<Result> results) |
static long |
calculateResultSize(Result result) |
static void |
deleteNamespaceQuota(Connection connection,
java.lang.String namespace) |
static void |
deleteTableQuota(Connection connection,
TableName table) |
static void |
deleteUserQuota(Connection connection,
java.lang.String user) |
static void |
deleteUserQuota(Connection connection,
java.lang.String user,
java.lang.String namespace) |
static void |
deleteUserQuota(Connection connection,
java.lang.String user,
TableName table) |
static <K> java.util.Map<K,QuotaState> |
fetchGlobalQuotas(java.lang.String type,
Connection connection,
java.util.List<Get> gets,
org.apache.hadoop.hbase.quotas.QuotaUtil.KeyFromRow<K> kfr) |
static java.util.Map<java.lang.String,QuotaState> |
fetchNamespaceQuotas(Connection connection,
java.util.List<Get> gets) |
static java.util.Map<TableName,QuotaState> |
fetchTableQuotas(Connection connection,
java.util.List<Get> gets) |
static java.util.Map<java.lang.String,UserQuotaState> |
fetchUserQuotas(Connection connection,
java.util.List<Get> gets) |
static boolean |
isQuotaEnabled(Configuration conf)
Returns true if the support for quota is enabled
|
doGet, doGet, extractQuotaSnapshot, getCurrentSnapshot, getCurrentSnapshot, getMasterReportedTableSizes, getNamespaceFromRowKey, getNamespaceQuota, getNamespaceRowKey, getNamespaceRowKeyRegex, getProtoViolationPolicy, getRegionServerQuotaSnapshots, getSettingsQualifierForUserNamespace, getSettingsQualifierForUserTable, getSettingsQualifierRegexForUserNamespace, getSettingsQualifierRegexForUserTable, getSnapshots, getTableFromRowKey, getTableQuota, getTableRowKey, getTableRowKeyRegex, getUserFromRowKey, getUserQuota, getUserQuota, getUserQuota, getUserRowKey, getUserRowKeyRegex, getViolationPolicy, isEmptyQuota, isNamespaceRowKey, isTableRowKey, isUserRowKey, makeFilter, makeGetForNamespaceQuotas, makeGetForTableQuotas, makeGetForUserQuotas, makeQuotaSnapshotScan, makeScan, parseNamespaceResult, parseNamespaceResult, parseResult, parseTableResult, parseTableResult, parseUserResult, parseUserResult, putSpaceSnapshot, quotasFromData, quotasFromData, quotasToData
public static final java.lang.String QUOTA_CONF_KEY
public static final HTableDescriptor QUOTA_TABLE_DESC
public static boolean isQuotaEnabled(Configuration conf)
public static void addTableQuota(Connection connection, TableName table, QuotaProtos.Quotas data) throws java.io.IOException
java.io.IOException
public static void deleteTableQuota(Connection connection, TableName table) throws java.io.IOException
java.io.IOException
public static void addNamespaceQuota(Connection connection, java.lang.String namespace, QuotaProtos.Quotas data) throws java.io.IOException
java.io.IOException
public static void deleteNamespaceQuota(Connection connection, java.lang.String namespace) throws java.io.IOException
java.io.IOException
public static void addUserQuota(Connection connection, java.lang.String user, QuotaProtos.Quotas data) throws java.io.IOException
java.io.IOException
public static void addUserQuota(Connection connection, java.lang.String user, TableName table, QuotaProtos.Quotas data) throws java.io.IOException
java.io.IOException
public static void addUserQuota(Connection connection, java.lang.String user, java.lang.String namespace, QuotaProtos.Quotas data) throws java.io.IOException
java.io.IOException
public static void deleteUserQuota(Connection connection, java.lang.String user) throws java.io.IOException
java.io.IOException
public static void deleteUserQuota(Connection connection, java.lang.String user, TableName table) throws java.io.IOException
java.io.IOException
public static void deleteUserQuota(Connection connection, java.lang.String user, java.lang.String namespace) throws java.io.IOException
java.io.IOException
public static java.util.Map<java.lang.String,UserQuotaState> fetchUserQuotas(Connection connection, java.util.List<Get> gets) throws java.io.IOException
java.io.IOException
public static java.util.Map<TableName,QuotaState> fetchTableQuotas(Connection connection, java.util.List<Get> gets) throws java.io.IOException
java.io.IOException
public static java.util.Map<java.lang.String,QuotaState> fetchNamespaceQuotas(Connection connection, java.util.List<Get> gets) throws java.io.IOException
java.io.IOException
public static <K> java.util.Map<K,QuotaState> fetchGlobalQuotas(java.lang.String type, Connection connection, java.util.List<Get> gets, org.apache.hadoop.hbase.quotas.QuotaUtil.KeyFromRow<K> kfr) throws java.io.IOException
java.io.IOException
public static long calculateMutationSize(Mutation mutation)
public static long calculateResultSize(Result result)
public static long calculateResultSize(java.util.List<Result> results)