org.apache.hadoop.hbase.quotas

Class MasterQuotaManager

java.lang.Object

org.apache.hadoop.hbase.quotas.MasterQuotaManager

All Implemented Interfaces:

RegionStateListener

@InterfaceAudience.Private
 @InterfaceStability.Evolving
public class MasterQuotaManager
extends java.lang.Object
implements RegionStateListener

Master Quota Manager. It is responsible for initialize the quota table on the first-run and provide the admin operations to interact with the quota table. TODO: FUTURE: The master will be responsible to notify each RS of quota changes and it will do the "quota aggregation" when the QuotaScope is CLUSTER.

Constructor Summary

Constructors

Constructor and Description
MasterQuotaManager(MasterServices masterServices)

Method Summary

Modifier and Type	Method and Description
void	addRegionSize(HRegionInfo hri, long size, long time)
void	checkAndUpdateNamespaceRegionQuota(TableName tName, int regions)
void	checkNamespaceTableAndRegionQuota(TableName tName, int regions)
NamespaceAuditor	getNamespaceQuotaManager()
int	getRegionCountOfTable(TableName tName)
boolean	isQuotaInitialized()
void	onRegionMerged(HRegionInfo hri) Process region merge event.
void	onRegionSplit(HRegionInfo hri) Process region split event.
void	onRegionSplitReverted(HRegionInfo hri) Process region split reverted event.
void	removeNamespaceQuota(java.lang.String namespace)
void	removeTableFromNamespaceQuota(TableName tName) Remove table from namespace quota.
void	setNamespaceQuota(NamespaceDescriptor desc)
void	setNamespaceQuota(java.lang.String namespace, MasterProtos.SetQuotaRequest req)
MasterProtos.SetQuotaResponse	setQuota(MasterProtos.SetQuotaRequest req)
void	setTableQuota(TableName table, MasterProtos.SetQuotaRequest req)
void	setUserQuota(java.lang.String userName, MasterProtos.SetQuotaRequest req)
void	setUserQuota(java.lang.String userName, java.lang.String namespace, MasterProtos.SetQuotaRequest req)
void	setUserQuota(java.lang.String userName, TableName table, MasterProtos.SetQuotaRequest req)
java.util.Map<HRegionInfo,java.lang.Long>	snapshotRegionSizes()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

MasterQuotaManager

public MasterQuotaManager(MasterServices masterServices)

Method Detail

start

public void start()
           throws java.io.IOException

Throws:

java.io.IOException

stop

public void stop()

isQuotaInitialized

public boolean isQuotaInitialized()

setQuota

public MasterProtos.SetQuotaResponse setQuota(MasterProtos.SetQuotaRequest req)
                                       throws java.io.IOException,
                                              java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

setUserQuota

public void setUserQuota(java.lang.String userName,
                         MasterProtos.SetQuotaRequest req)
                  throws java.io.IOException,
                         java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

setUserQuota

public void setUserQuota(java.lang.String userName,
                         TableName table,
                         MasterProtos.SetQuotaRequest req)
                  throws java.io.IOException,
                         java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

setUserQuota

public void setUserQuota(java.lang.String userName,
                         java.lang.String namespace,
                         MasterProtos.SetQuotaRequest req)
                  throws java.io.IOException,
                         java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

setTableQuota

public void setTableQuota(TableName table,
                          MasterProtos.SetQuotaRequest req)
                   throws java.io.IOException,
                          java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

setNamespaceQuota

public void setNamespaceQuota(java.lang.String namespace,
                              MasterProtos.SetQuotaRequest req)
                       throws java.io.IOException,
                              java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

setNamespaceQuota

public void setNamespaceQuota(NamespaceDescriptor desc)
                       throws java.io.IOException

Throws:

java.io.IOException

removeNamespaceQuota

public void removeNamespaceQuota(java.lang.String namespace)
                          throws java.io.IOException

Throws:

java.io.IOException

checkNamespaceTableAndRegionQuota

public void checkNamespaceTableAndRegionQuota(TableName tName,
                                              int regions)
                                       throws java.io.IOException

Throws:

java.io.IOException

checkAndUpdateNamespaceRegionQuota

public void checkAndUpdateNamespaceRegionQuota(TableName tName,
                                               int regions)
                                        throws java.io.IOException

Throws:

java.io.IOException

getRegionCountOfTable

public int getRegionCountOfTable(TableName tName)
                          throws java.io.IOException

Returns:

cached region count, or -1 if quota manager is disabled or table status not found

Throws:

java.io.IOException

onRegionMerged

public void onRegionMerged(HRegionInfo hri)
                    throws java.io.IOException

Description copied from interface: RegionStateListener

Process region merge event.

Specified by:

onRegionMerged in interface RegionStateListener

Parameters:

hri - An instance of HRegionInfo

Throws:

java.io.IOException

onRegionSplit

public void onRegionSplit(HRegionInfo hri)
                   throws java.io.IOException

Description copied from interface: RegionStateListener

Process region split event.

Specified by:

onRegionSplit in interface RegionStateListener

Parameters:

hri - An instance of HRegionInfo

Throws:

java.io.IOException

removeTableFromNamespaceQuota

public void removeTableFromNamespaceQuota(TableName tName)
                                   throws java.io.IOException

Remove table from namespace quota.

Parameters:

tName - - The table name to update quota usage.

Throws:

java.io.IOException - Signals that an I/O exception has occurred.

getNamespaceQuotaManager

public NamespaceAuditor getNamespaceQuotaManager()

onRegionSplitReverted

public void onRegionSplitReverted(HRegionInfo hri)
                           throws java.io.IOException

Description copied from interface: RegionStateListener

Process region split reverted event.

Specified by:

onRegionSplitReverted in interface RegionStateListener

Parameters:

hri - An instance of HRegionInfo

Throws:

java.io.IOException - Signals that an I/O exception has occurred.

addRegionSize

public void addRegionSize(HRegionInfo hri,
                          long size,
                          long time)

snapshotRegionSizes

public java.util.Map<HRegionInfo,java.lang.Long> snapshotRegionSizes()