| Package | Description |
|---|---|
| org.apache.hadoop.hbase.quotas | |
| org.apache.hadoop.hbase.quotas.policies |
| Modifier and Type | Field and Description |
|---|---|
static SpaceQuotaSnapshot |
QuotaSnapshotStore.NO_QUOTA
Singleton to represent a table without a quota defined.
|
| Modifier and Type | Method and Description |
|---|---|
Map<TableName,SpaceQuotaSnapshot> |
RegionServerSpaceQuotaManager.copyQuotaSnapshots()
Copies the last
SpaceQuotaSnapshots that were recorded. |
Map<TableName,SpaceQuotaSnapshot> |
SpaceQuotaSnapshotNotifierForTest.copySnapshots() |
Map<TableName,SpaceQuotaSnapshot> |
SpaceQuotaRefresherChore.fetchSnapshotsFromQuotaTable()
Reads all quota violation policies which are to be enforced from the quota table.
|
Map<TableName,SpaceQuotaSnapshot> |
RegionServerSpaceQuotaManager.getActivePoliciesAsMap()
Converts a map of table to
SpaceViolationPolicyEnforcements into
SpaceViolationPolicys. |
static Map<TableName,SpaceQuotaSnapshot> |
QuotaTableUtil.getRegionServerQuotaSnapshots(Connection conn,
ServerName regionServer)
Fetches the observed
SpaceQuotaSnapshots observed by a RegionServer. |
| Modifier and Type | Method and Description |
|---|---|
SpaceViolationPolicyEnforcement |
SpaceViolationPolicyEnforcementFactory.create(RegionServerServices rss,
TableName tableName,
SpaceQuotaSnapshot snapshot)
Constructs the appropriate
SpaceViolationPolicyEnforcement for tables that are
in violation of their space quota. |
SpaceViolationPolicyEnforcement |
SpaceViolationPolicyEnforcementFactory.createWithoutViolation(RegionServerServices rss,
TableName tableName,
SpaceQuotaSnapshot snapshot)
Creates the "default"
SpaceViolationPolicyEnforcement for a table that isn't in
violation. |
void |
RegionServerSpaceQuotaManager.enforceViolationPolicy(TableName tableName,
SpaceQuotaSnapshot snapshot)
Enforces the given violationPolicy on the given table in this RegionServer.
|
void |
SpaceViolationPolicyEnforcement.initialize(RegionServerServices rss,
TableName tableName,
SpaceQuotaSnapshot snapshot)
Initializes this policy instance.
|
static Put |
QuotaTableUtil.putSpaceSnapshot(TableName tableName,
SpaceQuotaSnapshot snapshot)
|
void |
NamespaceQuotaSnapshotStore.setCurrentState(String namespace,
SpaceQuotaSnapshot snapshot) |
void |
TableQuotaSnapshotStore.setCurrentState(TableName table,
SpaceQuotaSnapshot snapshot) |
void |
QuotaSnapshotStore.setCurrentState(T subject,
SpaceQuotaSnapshot state)
Sets the current
QuotaSnapshotStore.ViolationState for the subject. |
static QuotaProtos.SpaceQuotaSnapshot |
SpaceQuotaSnapshot.toProtoSnapshot(SpaceQuotaSnapshot snapshot) |
void |
SpaceQuotaSnapshotNotifier.transitionTable(TableName tableName,
SpaceQuotaSnapshot snapshot)
Instructs the cluster that the given table is in violation of a space quota.
|
void |
TableSpaceQuotaSnapshotNotifier.transitionTable(TableName tableName,
SpaceQuotaSnapshot snapshot) |
void |
SpaceQuotaSnapshotNotifierForTest.transitionTable(TableName tableName,
SpaceQuotaSnapshot snapshot) |
| Modifier and Type | Method and Description |
|---|---|
static void |
QuotaTableUtil.extractQuotaSnapshot(Result result,
Map<TableName,SpaceQuotaSnapshot> snapshots)
Extracts the
SpaceViolationPolicy and TableName from the provided
Result and adds them to the given Map. |
void |
RegionServerSpaceQuotaManager.updateQuotaSnapshot(Map<TableName,SpaceQuotaSnapshot> newSnapshots)
Updates the current
SpaceQuotaSnapshots for the RegionServer. |
| Constructor and Description |
|---|
ActivePolicyEnforcement(Map<TableName,SpaceViolationPolicyEnforcement> activePolicies,
Map<TableName,SpaceQuotaSnapshot> snapshots,
RegionServerServices rss) |
| Modifier and Type | Method and Description |
|---|---|
SpaceQuotaSnapshot |
AbstractViolationPolicyEnforcement.getQuotaSnapshot() |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractViolationPolicyEnforcement.initialize(RegionServerServices rss,
TableName tableName,
SpaceQuotaSnapshot snapshot) |
void |
AbstractViolationPolicyEnforcement.setQuotaSnapshot(SpaceQuotaSnapshot snapshot) |