org.apache.hadoop.hbase.namespace

Class NamespaceStateManager

java.lang.Object

org.apache.hadoop.hbase.namespace.NamespaceStateManager

@InterfaceAudience.Private
class NamespaceStateManager
extends Object

NamespaceStateManager manages state (in terms of quota) of all the namespaces. It contains a cache which is updated based on the hooks in the NamespaceAuditor class.

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	initialized
private static org.slf4j.Logger	LOG
private MasterServices	master
private ConcurrentMap<String,NamespaceTableAndRegionInfo>	nsStateCache

Constructor Summary

Constructors

Constructor and Description
NamespaceStateManager(MasterServices masterServices)

Method Summary

Modifier and Type	Method and Description
(package private) NamespaceTableAndRegionInfo	addNamespace(String namespace)
private void	addTable(TableName tableName, int regionCount)
(package private) boolean	checkAndUpdateNamespaceRegionCount(TableName name, byte[] regionName, int incr) Check if adding a region violates namespace quota, if not update namespace cache.
(package private) void	checkAndUpdateNamespaceRegionCount(TableName name, int incr) Check and update region count for an existing table.
(package private) void	checkAndUpdateNamespaceTableCount(TableName table, int numRegions)
(package private) void	deleteNamespace(String namespace) Delete the namespace state.
private NamespaceDescriptor	getNamespaceDescriptor(String namespaceAsString)
NamespaceTableAndRegionInfo	getState(String name) Gets an instance of NamespaceTableAndRegionInfo associated with namespace.
private void	initialize() Initialize namespace state cache by scanning meta table.
(package private) boolean	isInitialized()
void	removeRegionFromTable(RegionInfo hri)
(package private) void	removeTable(TableName tableName)
void	start() Starts the NamespaceStateManager.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

nsStateCache

private ConcurrentMap<String,NamespaceTableAndRegionInfo> nsStateCache

master

private MasterServices master

initialized

private volatile boolean initialized

Constructor Detail

NamespaceStateManager

public NamespaceStateManager(MasterServices masterServices)

Method Detail

start

public void start()
           throws IOException

Starts the NamespaceStateManager. The boot strap of cache is done in the post master start hook of the NamespaceAuditor class.

Throws:

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

getState

public NamespaceTableAndRegionInfo getState(String name)

Gets an instance of NamespaceTableAndRegionInfo associated with namespace.

Parameters:

name - The name of the namespace

Returns:

An instance of NamespaceTableAndRegionInfo.

checkAndUpdateNamespaceRegionCount

boolean checkAndUpdateNamespaceRegionCount(TableName name,
                                           byte[] regionName,
                                           int incr)
                                    throws IOException

Check if adding a region violates namespace quota, if not update namespace cache. nnn * @return true, if region can be added to table.

Throws:

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

checkAndUpdateNamespaceRegionCount

void checkAndUpdateNamespaceRegionCount(TableName name,
                                        int incr)
                                 throws IOException

Check and update region count for an existing table. To handle scenarios like restore snapshot

Parameters:

name - name of the table for region count needs to be checked and updated

incr - count of regions

Throws:

QuotaExceededException - if quota exceeds for the number of regions allowed in a namespace

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

getNamespaceDescriptor

private NamespaceDescriptor getNamespaceDescriptor(String namespaceAsString)

checkAndUpdateNamespaceTableCount

void checkAndUpdateNamespaceTableCount(TableName table,
                                       int numRegions)
                                throws IOException

Throws:

IOException

addNamespace

NamespaceTableAndRegionInfo addNamespace(String namespace)

deleteNamespace

void deleteNamespace(String namespace)

Delete the namespace state.

Parameters:

namespace - the name of the namespace to delete

addTable

private void addTable(TableName tableName,
                      int regionCount)
               throws IOException

Throws:

IOException

removeTable

void removeTable(TableName tableName)

initialize

private void initialize()
                 throws IOException

Initialize namespace state cache by scanning meta table.

Throws:

IOException

isInitialized

boolean isInitialized()

removeRegionFromTable

public void removeRegionFromTable(RegionInfo hri)
                           throws IOException

Throws:

IOException