org.apache.hadoop.hbase.master

Class TableNamespaceManager

java.lang.Object

org.apache.hadoop.hbase.master.TableNamespaceManager

public class TableNamespaceManager
extends java.lang.Object

This is a helper class used internally to manage the namespace metadata that is stored in TableName.NAMESPACE_TABLE_NAME. It also mirrors updates to the ZK store by forwarding updates to ZKNamespaceManager. WARNING: Do not use. Go via the higher-level ClusterSchema API instead. This manager is likely to go aways anyways.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	KEY_MAX_REGIONS
static java.lang.String	KEY_MAX_TABLES

Method Summary

Modifier and Type	Method and Description
boolean	doesNamespaceExist(java.lang.String namespaceName)
NamespaceDescriptor	get(java.lang.String name)
static long	getMaxRegions(NamespaceDescriptor ns)
static long	getMaxTables(NamespaceDescriptor ns)
void	insertIntoNSTable(NamespaceDescriptor ns)
boolean	isStopped()
boolean	isTableAvailableAndInitialized() This method checks if the namespace table is assigned and then tries to create its Table reference.
java.util.NavigableSet<NamespaceDescriptor>	list()
void	removeFromNSTable(java.lang.String namespaceName)
void	removeFromZKNamespaceManager(java.lang.String namespaceName)
void	start()
void	stop(java.lang.String why)
void	updateZKNamespaceManager(NamespaceDescriptor ns)
void	validateTableAndRegionCount(NamespaceDescriptor desc)

Methods inherited from class java.lang.Object

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

Field Detail

KEY_MAX_REGIONS

public static final java.lang.String KEY_MAX_REGIONS

See Also:

Constant Field Values

KEY_MAX_TABLES

public static final java.lang.String KEY_MAX_TABLES

See Also:

Constant Field Values

Method Detail

start

public void start()
           throws java.io.IOException

Throws:

java.io.IOException

doesNamespaceExist

public boolean doesNamespaceExist(java.lang.String namespaceName)
                           throws java.io.IOException

Throws:

java.io.IOException

get

public NamespaceDescriptor get(java.lang.String name)
                        throws java.io.IOException

Throws:

java.io.IOException

insertIntoNSTable

public void insertIntoNSTable(NamespaceDescriptor ns)
                       throws java.io.IOException

Throws:

java.io.IOException

updateZKNamespaceManager

public void updateZKNamespaceManager(NamespaceDescriptor ns)
                              throws java.io.IOException

Throws:

java.io.IOException

removeFromNSTable

public void removeFromNSTable(java.lang.String namespaceName)
                       throws java.io.IOException

Throws:

java.io.IOException

removeFromZKNamespaceManager

public void removeFromZKNamespaceManager(java.lang.String namespaceName)
                                  throws java.io.IOException

Throws:

java.io.IOException

list

public java.util.NavigableSet<NamespaceDescriptor> list()
                                                 throws java.io.IOException

Throws:

java.io.IOException

isTableAvailableAndInitialized

public boolean isTableAvailableAndInitialized()
                                       throws java.io.IOException

This method checks if the namespace table is assigned and then tries to create its Table reference. If it was already created before, it also makes sure that the connection isn't closed.

Returns:

true if the namespace table manager is ready to serve, false otherwise

Throws:

java.io.IOException

validateTableAndRegionCount

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

Throws:

java.io.IOException

getMaxTables

public static long getMaxTables(NamespaceDescriptor ns)
                         throws java.io.IOException

Throws:

java.io.IOException

getMaxRegions

public static long getMaxRegions(NamespaceDescriptor ns)
                          throws java.io.IOException

Throws:

java.io.IOException

isStopped

public boolean isStopped()

stop

public void stop(java.lang.String why)