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 |
---|---|
static SpaceQuotaSnapshot |
QuotaTableUtil.getCurrentSnapshot(Connection conn,
String namespace)
Returns the Master's view of a quota on the given
namespace or null if the
Master has no quota information on that namespace. |
static SpaceQuotaSnapshot |
QuotaTableUtil.getCurrentSnapshot(Connection conn,
TableName tn)
Returns the Master's view of a quota on the given
tableName or null if the
Master has no quota information on that table. |
static SpaceQuotaSnapshot |
QuotaTableUtil.getCurrentSnapshotFromQuotaTable(Connection conn,
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. |
SpaceQuotaSnapshot |
NamespaceQuotaSnapshotStore.getCurrentState(String namespace) |
SpaceQuotaSnapshot |
QuotaSnapshotStore.getCurrentState(T subject)
Returns the current
SpaceQuotaSnapshot for the given subject . |
SpaceQuotaSnapshot |
TableQuotaSnapshotStore.getCurrentState(TableName table) |
static SpaceQuotaSnapshot |
SpaceQuotaSnapshot.getNoSuchSnapshot()
Returns a singleton that corresponds to no snapshot information.
|
SpaceQuotaSnapshot |
SpaceViolationPolicyEnforcement.getQuotaSnapshot()
Returns the
SpaceQuotaSnapshot this was initialized with. |
SpaceQuotaSnapshot |
NamespaceQuotaSnapshotStore.getTargetState(String subject,
QuotaProtos.SpaceQuota spaceQuota) |
SpaceQuotaSnapshot |
TableQuotaSnapshotStore.getTargetState(TableName table,
QuotaProtos.SpaceQuota spaceQuota) |
SpaceQuotaSnapshot |
QuotaSnapshotStore.getTargetState(T subject,
QuotaProtos.SpaceQuota spaceQuota)
|
static SpaceQuotaSnapshot |
SpaceQuotaSnapshot.toSpaceQuotaSnapshot(QuotaProtos.SpaceQuotaSnapshot proto) |
Modifier and Type | Method and Description |
---|---|
Map<TableName,SpaceQuotaSnapshot> |
RegionServerSpaceQuotaManager.copyQuotaSnapshots()
Copies the last
SpaceQuotaSnapshot s that were recorded. |
Map<TableName,SpaceQuotaSnapshot> |
SpaceQuotaRefresherChore.fetchSnapshotsFromQuotaTable()
Reads all quota snapshots from the quota table.
|
Map<TableName,SpaceQuotaSnapshot> |
RegionServerSpaceQuotaManager.getActivePoliciesAsMap()
Converts a map of table to
SpaceViolationPolicyEnforcement s into
SpaceViolationPolicy s. |
Map<String,SpaceQuotaSnapshot> |
QuotaObserverChore.getNamespaceQuotaSnapshots()
Returns an unmodifiable view over the current
SpaceQuotaSnapshot objects
for each HBase namespace with a quota defined. |
static Map<TableName,SpaceQuotaSnapshot> |
QuotaTableUtil.getRegionServerQuotaSnapshots(Connection conn,
ServerName regionServer)
Fetches the observed
SpaceQuotaSnapshot s observed by a RegionServer. |
static Map<TableName,SpaceQuotaSnapshot> |
QuotaTableUtil.getSnapshots(Connection conn)
Fetches all
SpaceQuotaSnapshot objects from the hbase:quota table. |
Map<TableName,SpaceQuotaSnapshot> |
QuotaObserverChore.getTableQuotaSnapshots()
Returns an unmodifiable view over the current
SpaceQuotaSnapshot objects
for each HBase table with a quota defined. |
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.
|
void |
NamespaceQuotaSnapshotStore.setCurrentState(String namespace,
SpaceQuotaSnapshot snapshot) |
void |
TableQuotaSnapshotStore.setCurrentState(TableName table,
SpaceQuotaSnapshot snapshot) |
void |
QuotaSnapshotStore.setCurrentState(T subject,
SpaceQuotaSnapshot state)
Persists the current
SpaceQuotaSnapshot for the subject . |
static QuotaProtos.SpaceQuotaSnapshot |
SpaceQuotaSnapshot.toProtoSnapshot(SpaceQuotaSnapshot snapshot) |
void |
TableSpaceQuotaSnapshotNotifier.transitionTable(TableName tableName,
SpaceQuotaSnapshot snapshot) |
void |
SpaceQuotaSnapshotNotifier.transitionTable(TableName tableName,
SpaceQuotaSnapshot snapshot)
Informs the cluster of the current state of a space quota for a table.
|
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
SpaceQuotaSnapshot s for the RegionServer. |
Constructor and Description |
---|
ActivePolicyEnforcement(Map<TableName,SpaceViolationPolicyEnforcement> activePolicies,
Map<TableName,SpaceQuotaSnapshot> snapshots,
RegionServerServices rss) |
ActivePolicyEnforcement(Map<TableName,SpaceViolationPolicyEnforcement> activePolicies,
Map<TableName,SpaceQuotaSnapshot> snapshots,
RegionServerServices rss,
SpaceViolationPolicyEnforcementFactory factory) |
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) |
Copyright © 2007–2019 Cloudera. All rights reserved.