static org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot
QuotaTableUtil.getCurrentSnapshotFromQuotaTable(org.apache.hadoop.hbase.client.Connection conn,
org.apache.hadoop.hbase.TableName tableName)
Returns the current space quota snapshot of the given tableName
from
QuotaTableUtil.QUOTA_TABLE_NAME
or null if the no quota information is available for
that tableName.
org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot
NamespaceQuotaSnapshotStore.getCurrentState(String namespace)
org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot
QuotaSnapshotStore.getCurrentState(T subject)
Returns the current SpaceQuotaSnapshot
for the given subject
.
org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot
TableQuotaSnapshotStore.getCurrentState(org.apache.hadoop.hbase.TableName table)
static org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot
SpaceQuotaSnapshot.getNoSuchSnapshot()
Returns a singleton that corresponds to no snapshot information.
org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot
SpaceViolationPolicyEnforcement.getQuotaSnapshot()
Returns the SpaceQuotaSnapshot
this
was initialized with.
org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot
NamespaceQuotaSnapshotStore.getTargetState(String subject,
org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceQuota spaceQuota)
org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot
QuotaSnapshotStore.getTargetState(T subject,
org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceQuota spaceQuota)
Computes the target SpaceQuotaSnapshot
for the given subject
and
spaceQuota
.
org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot
TableQuotaSnapshotStore.getTargetState(org.apache.hadoop.hbase.TableName table,
org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceQuota spaceQuota)
static org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot
SpaceQuotaSnapshot.toSpaceQuotaSnapshot(org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceQuotaSnapshot proto)
Map<org.apache.hadoop.hbase.TableName,org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot>
RegionServerSpaceQuotaManager.copyQuotaSnapshots()
Copies the last SpaceQuotaSnapshot
s that were recorded.
Map<org.apache.hadoop.hbase.TableName,org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot>
SpaceQuotaRefresherChore.fetchSnapshotsFromQuotaTable()
Reads all quota snapshots from the quota table.
Map<org.apache.hadoop.hbase.TableName,org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot>
RegionServerSpaceQuotaManager.getActivePoliciesAsMap()
Converts a map of table to SpaceViolationPolicyEnforcement
s into
SpaceViolationPolicy
s.
Map<String,org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot>
QuotaObserverChore.getNamespaceQuotaSnapshots()
Returns an unmodifiable view over the current SpaceQuotaSnapshot
objects for each HBase
namespace with a quota defined.
static Map<org.apache.hadoop.hbase.TableName,org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot>
QuotaTableUtil.getSnapshots(org.apache.hadoop.hbase.client.Connection conn)
Fetches all SpaceQuotaSnapshot
objects from the hbase:quota
table.
Map<org.apache.hadoop.hbase.TableName,org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot>
QuotaObserverChore.getTableQuotaSnapshots()
Returns an unmodifiable view over the current SpaceQuotaSnapshot
objects for each HBase
table with a quota defined.
org.apache.hadoop.hbase.quotas.SpaceViolationPolicyEnforcement
SpaceViolationPolicyEnforcementFactory.create(org.apache.hadoop.hbase.regionserver.RegionServerServices rss,
org.apache.hadoop.hbase.TableName tableName,
org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot snapshot)
Constructs the appropriate SpaceViolationPolicyEnforcement
for tables that are in
violation of their space quota.
org.apache.hadoop.hbase.quotas.SpaceViolationPolicyEnforcement
SpaceViolationPolicyEnforcementFactory.createWithoutViolation(org.apache.hadoop.hbase.regionserver.RegionServerServices rss,
org.apache.hadoop.hbase.TableName tableName,
org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot snapshot)
Creates the "default" SpaceViolationPolicyEnforcement
for a table that isn't in
violation.
void
RegionServerSpaceQuotaManager.enforceViolationPolicy(org.apache.hadoop.hbase.TableName tableName,
org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot snapshot)
Enforces the given violationPolicy on the given table in this RegionServer.
void
SpaceViolationPolicyEnforcement.initialize(org.apache.hadoop.hbase.regionserver.RegionServerServices rss,
org.apache.hadoop.hbase.TableName tableName,
org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot snapshot)
Initializes this policy instance.
void
NamespaceQuotaSnapshotStore.setCurrentState(String namespace,
org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot snapshot)
void
QuotaSnapshotStore.setCurrentState(T subject,
org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot state)
Persists the current SpaceQuotaSnapshot
for the subject
.
void
TableQuotaSnapshotStore.setCurrentState(org.apache.hadoop.hbase.TableName table,
org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot snapshot)
static org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceQuotaSnapshot
SpaceQuotaSnapshot.toProtoSnapshot(org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot snapshot)
void
SpaceQuotaSnapshotNotifier.transitionTable(org.apache.hadoop.hbase.TableName tableName,
org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot snapshot)
Informs the cluster of the current state of a space quota for a table.
void
TableSpaceQuotaSnapshotNotifier.transitionTable(org.apache.hadoop.hbase.TableName tableName,
org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot snapshot)