org.apache.hadoop.hbase.quotas

Class TableQuotaSnapshotStore

java.lang.Object

org.apache.hadoop.hbase.quotas.TableQuotaSnapshotStore

All Implemented Interfaces:

QuotaSnapshotStore<TableName>

public class TableQuotaSnapshotStore
extends java.lang.Object
implements QuotaSnapshotStore<TableName>

QuotaSnapshotStore for tables.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.quotas.QuotaSnapshotStore

QuotaSnapshotStore.ViolationState

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, java.util.Map<HRegionInfo,java.lang.Long> regionUsage)

Method Summary

Modifier and Type	Method and Description
java.lang.Iterable<java.util.Map.Entry<HRegionInfo,java.lang.Long>>	filterBySubject(TableName table) Filters the provided regions, returning those which match the given subject.
SpaceQuotaSnapshot	getCurrentState(TableName table) Returns the current QuotaSnapshotStore.ViolationState for the given subject.
QuotaProtos.SpaceQuota	getSpaceQuota(TableName subject) Fetch the Quota for the given table.
SpaceQuotaSnapshot	getTargetState(TableName table, QuotaProtos.SpaceQuota spaceQuota) Computes the target QuotaSnapshotStore.ViolationState for the given subject.
void	setCurrentState(TableName table, SpaceQuotaSnapshot snapshot) Sets the current QuotaSnapshotStore.ViolationState for the subject.
void	setRegionUsage(java.util.Map<HRegionInfo,java.lang.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,
                               java.util.Map<HRegionInfo,java.lang.Long> regionUsage)

Method Detail

getSpaceQuota

public QuotaProtos.SpaceQuota getSpaceQuota(TableName subject)
                                     throws java.io.IOException

Description copied from interface: QuotaSnapshotStore

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

Specified by:

getSpaceQuota in interface QuotaSnapshotStore<TableName>

Throws:

java.io.IOException

getCurrentState

public SpaceQuotaSnapshot getCurrentState(TableName table)

Description copied from interface: QuotaSnapshotStore

Returns the current QuotaSnapshotStore.ViolationState for the given subject.

Specified by:

getCurrentState in interface QuotaSnapshotStore<TableName>

getTargetState

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

Description copied from interface: QuotaSnapshotStore

Computes the target QuotaSnapshotStore.ViolationState for the given subject.

Specified by:

getTargetState in interface QuotaSnapshotStore<TableName>

filterBySubject

public java.lang.Iterable<java.util.Map.Entry<HRegionInfo,java.lang.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.

setCurrentState

public void setCurrentState(TableName table,
                            SpaceQuotaSnapshot snapshot)

Description copied from interface: QuotaSnapshotStore

Sets the current QuotaSnapshotStore.ViolationState for the subject.

Specified by:

setCurrentState in interface QuotaSnapshotStore<TableName>

setRegionUsage

public void setRegionUsage(java.util.Map<HRegionInfo,java.lang.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 HRegionInfo objects to their filesystem usage in bytes