org.apache.hadoop.hbase.quotas

Class TableQuotaSnapshotStore

java.lang.Object

org.apache.hadoop.hbase.quotas.TableQuotaSnapshotStore

All Implemented Interfaces:

QuotaSnapshotStore<TableName>

@InterfaceAudience.Private
public class TableQuotaSnapshotStore
extends Object
implements QuotaSnapshotStore<TableName>

QuotaSnapshotStore for tables.

Field Summary

Fields inherited from interface org.apache.hadoop.hbase.quotas.QuotaSnapshotStore

NO_QUOTA

Constructor Summary

Constructors

Constructor and Description
TableQuotaSnapshotStore(Connection conn, QuotaObserverChore chore, Map<RegionInfo,Long> regionUsage)

Method Summary

Modifier and Type	Method and Description
Iterable<Map.Entry<RegionInfo,Long>>	filterBySubject(TableName table) Filters the provided regions, returning those which match the given subject.
SpaceQuotaSnapshot	getCurrentState(TableName table) Returns the current SpaceQuotaSnapshot for the given subject.
QuotaProtos.SpaceQuota	getSpaceQuota(TableName subject) Fetch the Quota for the given subject.
SpaceQuotaSnapshot	getTargetState(TableName table, QuotaProtos.SpaceQuota spaceQuota) Computes the target SpaceQuotaSnapshot for the given subject and spaceQuota.
void	setCurrentState(TableName table, SpaceQuotaSnapshot snapshot) Persists the current SpaceQuotaSnapshot for the subject.
void	setRegionUsage(Map<RegionInfo,Long> regionUsage) Updates this with the latest snapshot of filesystem use by region.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TableQuotaSnapshotStore

public TableQuotaSnapshotStore(Connection conn,
                               QuotaObserverChore chore,
                               Map<RegionInfo,Long> regionUsage)

Method Detail

getSpaceQuota

public QuotaProtos.SpaceQuota getSpaceQuota(TableName subject)
                                     throws IOException

Description copied from interface: QuotaSnapshotStore

Fetch the Quota for the given subject. May be null.

Specified by:

getSpaceQuota in interface QuotaSnapshotStore<TableName>

Parameters:

subject - The object for which the quota should be fetched

Throws:

IOException

getCurrentState

public SpaceQuotaSnapshot getCurrentState(TableName table)

Description copied from interface: QuotaSnapshotStore

Returns the current SpaceQuotaSnapshot for the given subject.

Specified by:

getCurrentState in interface QuotaSnapshotStore<TableName>

Parameters:

table - The object which the quota snapshot should be fetched

getTargetState

public SpaceQuotaSnapshot getTargetState(TableName table,
                                         QuotaProtos.SpaceQuota spaceQuota)
                                  throws IOException

Description copied from interface: QuotaSnapshotStore

Computes the target SpaceQuotaSnapshot for the given subject and spaceQuota.

Specified by:

getTargetState in interface QuotaSnapshotStore<TableName>

Parameters:

table - The object which to determine the target SpaceQuotaSnapshot of

spaceQuota - The quota "definition" for the subject

Throws:

IOException

filterBySubject

public Iterable<Map.Entry<RegionInfo,Long>> filterBySubject(TableName table)

Description copied from interface: QuotaSnapshotStore

Filters the provided regions, returning those which match the given subject.

Specified by:

filterBySubject in interface QuotaSnapshotStore<TableName>

Parameters:

table - The filter criteria. Only regions belonging to this parameter will be returned

setCurrentState

public void setCurrentState(TableName table,
                            SpaceQuotaSnapshot snapshot)

Description copied from interface: QuotaSnapshotStore

Persists the current SpaceQuotaSnapshot for the subject.

Specified by:

setCurrentState in interface QuotaSnapshotStore<TableName>

Parameters:

table - The object which the SpaceQuotaSnapshot is being persisted for

snapshot - The current state of the subject

setRegionUsage

public void setRegionUsage(Map<RegionInfo,Long> regionUsage)

Description copied from interface: QuotaSnapshotStore

Updates this with the latest snapshot of filesystem use by region.

Specified by:

setRegionUsage in interface QuotaSnapshotStore<TableName>

Parameters:

regionUsage - A map of RegionInfo objects to their filesystem usage in bytes