org.apache.hadoop.hbase.quotas

Class NamespaceQuotaSnapshotStore

java.lang.Object

org.apache.hadoop.hbase.quotas.NamespaceQuotaSnapshotStore

All Implemented Interfaces:

QuotaSnapshotStore<java.lang.String>

public class NamespaceQuotaSnapshotStore
extends java.lang.Object
implements QuotaSnapshotStore<java.lang.String>

QuotaSnapshotStore implementation for namespaces.

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
NamespaceQuotaSnapshotStore(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(java.lang.String namespace) Filters the provided regions, returning those which match the given subject.
SpaceQuotaSnapshot	getCurrentState(java.lang.String namespace) Returns the current QuotaSnapshotStore.ViolationState for the given subject.
QuotaProtos.SpaceQuota	getSpaceQuota(java.lang.String namespace) Fetch the Quota for the given table.
SpaceQuotaSnapshot	getTargetState(java.lang.String subject, QuotaProtos.SpaceQuota spaceQuota) Computes the target QuotaSnapshotStore.ViolationState for the given subject.
void	setCurrentState(java.lang.String namespace, 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

NamespaceQuotaSnapshotStore

public NamespaceQuotaSnapshotStore(Connection conn,
                                   QuotaObserverChore chore,
                                   java.util.Map<HRegionInfo,java.lang.Long> regionUsage)

Method Detail

getSpaceQuota

public QuotaProtos.SpaceQuota getSpaceQuota(java.lang.String namespace)
                                     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<java.lang.String>

Throws:

java.io.IOException

getCurrentState

public SpaceQuotaSnapshot getCurrentState(java.lang.String namespace)

Description copied from interface: QuotaSnapshotStore

Returns the current QuotaSnapshotStore.ViolationState for the given subject.

Specified by:

getCurrentState in interface QuotaSnapshotStore<java.lang.String>

getTargetState

public SpaceQuotaSnapshot getTargetState(java.lang.String subject,
                                         QuotaProtos.SpaceQuota spaceQuota)

Description copied from interface: QuotaSnapshotStore

Computes the target QuotaSnapshotStore.ViolationState for the given subject.

Specified by:

getTargetState in interface QuotaSnapshotStore<java.lang.String>

filterBySubject

public java.lang.Iterable<java.util.Map.Entry<HRegionInfo,java.lang.Long>> filterBySubject(java.lang.String namespace)

Description copied from interface: QuotaSnapshotStore

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

Specified by:

filterBySubject in interface QuotaSnapshotStore<java.lang.String>

Parameters:

namespace - The filter criteria.

setCurrentState

public void setCurrentState(java.lang.String namespace,
                            SpaceQuotaSnapshot snapshot)

Description copied from interface: QuotaSnapshotStore

Sets the current QuotaSnapshotStore.ViolationState for the subject.

Specified by:

setCurrentState in interface QuotaSnapshotStore<java.lang.String>

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<java.lang.String>

Parameters:

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