Package org.apache.hadoop.hbase.quotas

Class TableQuotaSnapshotStore

java.lang.Object

org.apache.hadoop.hbase.quotas.TableQuotaSnapshotStore

All Implemented Interfaces:

QuotaSnapshotStore<TableName>

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

QuotaSnapshotStore for tables.

Field Summary

Fields

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

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

NO_QUOTA

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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.
(package private) org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas	getQuotaForTable(TableName table)	Fetches the table quota.
(package private) long	getSnapshotSizesForTable(TableName tn)	Fetches any serialized snapshot sizes from the quota table for the tn provided.
org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceQuota	getSpaceQuota(TableName subject)	Fetch the Quota for the given subject.
SpaceQuotaSnapshot	getTargetState(TableName table, org.apache.hadoop.hbase.shaded.protobuf.generated.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

Field Details

LOG

private static final org.slf4j.Logger LOG

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 Details

TableQuotaSnapshotStore

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

Method Details

getSpaceQuota

public org.apache.hadoop.hbase.shaded.protobuf.generated.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

getQuotaForTable

org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas getQuotaForTable(TableName table)
                                                                               throws IOException

Fetches the table quota. Visible for mocking/testing.

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,
 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<TableName>

Parameters:

table - The object which to determine the target SpaceQuotaSnapshot of

spaceQuota - The quota "definition" for the subject

Throws:

IOException

getSnapshotSizesForTable

long getSnapshotSizesForTable(TableName tn)
                       throws IOException

Fetches any serialized snapshot sizes from the quota table for the tn provided. Any malformed records are skipped with a warning printed out.

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