org.apache.hadoop.hbase.quotas

Class NamespaceQuotaSnapshotStore

java.lang.Object

org.apache.hadoop.hbase.quotas.NamespaceQuotaSnapshotStore

All Implemented Interfaces:

QuotaSnapshotStore<String>

@InterfaceAudience.Private
public class NamespaceQuotaSnapshotStore
extends Object
implements QuotaSnapshotStore<String>

QuotaSnapshotStore implementation for namespaces.

Field Summary

Fields

Modifier and Type	Field and Description
private QuotaObserverChore	chore
private Connection	conn
private ReentrantReadWriteLock	lock
private Map<RegionInfo,Long>	regionUsage
private ReentrantReadWriteLock.ReadLock	rlock
private ReentrantReadWriteLock.WriteLock	wlock

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

NO_QUOTA

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Iterable<Map.Entry<RegionInfo,Long>>	filterBySubject(String namespace) Filters the provided regions, returning those which match the given subject.
SpaceQuotaSnapshot	getCurrentState(String namespace) Returns the current SpaceQuotaSnapshot for the given subject.
(package private) org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas	getQuotaForNamespace(String namespace) Fetches the namespace quota.
org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceQuota	getSpaceQuota(String namespace) Fetch the Quota for the given subject.
SpaceQuotaSnapshot	getTargetState(String subject, org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceQuota spaceQuota) Computes the target SpaceQuotaSnapshot for the given subject and spaceQuota.
void	setCurrentState(String namespace, 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

Field Detail

lock

private final ReentrantReadWriteLock lock

rlock

private final ReentrantReadWriteLock.ReadLock rlock

wlock

private final ReentrantReadWriteLock.WriteLock wlock

conn

private final Connection conn

chore

private final QuotaObserverChore chore

regionUsage

private Map<RegionInfo,Long> regionUsage

Constructor Detail

NamespaceQuotaSnapshotStore

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

Method Detail

getSpaceQuota

public org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceQuota getSpaceQuota(String namespace)
                                                                                       throws IOException

Description copied from interface: QuotaSnapshotStore

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

Specified by:

getSpaceQuota in interface QuotaSnapshotStore<String>

Parameters:

namespace - The object for which the quota should be fetched

Throws:

IOException

getQuotaForNamespace

org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas getQuotaForNamespace(String namespace)
                                                                                   throws IOException

Fetches the namespace quota. Visible for mocking/testing.

Throws:

IOException

getCurrentState

public SpaceQuotaSnapshot getCurrentState(String namespace)

Description copied from interface: QuotaSnapshotStore

Returns the current SpaceQuotaSnapshot for the given subject.

Specified by:

getCurrentState in interface QuotaSnapshotStore<String>

Parameters:

namespace - The object which the quota snapshot should be fetched

getTargetState

public SpaceQuotaSnapshot getTargetState(String subject,
                                         org.apache.hadoop.hbase.shaded.protobuf.generated.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<String>

Parameters:

subject - 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(String namespace)

Description copied from interface: QuotaSnapshotStore

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

Specified by:

filterBySubject in interface QuotaSnapshotStore<String>

Parameters:

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

setCurrentState

public void setCurrentState(String namespace,
                            SpaceQuotaSnapshot snapshot)

Description copied from interface: QuotaSnapshotStore

Persists the current SpaceQuotaSnapshot for the subject.

Specified by:

setCurrentState in interface QuotaSnapshotStore<String>

Parameters:

namespace - 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<String>

Parameters:

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