org.apache.hadoop.hbase.master

Class TableNamespaceManager

java.lang.Object

org.apache.hadoop.hbase.master.TableNamespaceManager

All Implemented Interfaces:

Stoppable

@InterfaceAudience.Private
public class TableNamespaceManager
extends Object
implements Stoppable

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 String	KEY_MAX_REGIONS
static String	KEY_MAX_TABLES

Method Summary

Modifier and Type	Method and Description
boolean	doesNamespaceExist(String namespaceName)
NamespaceDescriptor	get(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.
NavigableSet<NamespaceDescriptor>	list()
void	removeFromNSTable(String namespaceName)
void	removeFromZKNamespaceManager(String namespaceName)
void	start()
void	stop(String why) Stop this service.
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 String KEY_MAX_REGIONS

See Also:

Constant Field Values

KEY_MAX_TABLES

public static final String KEY_MAX_TABLES

See Also:

Constant Field Values

Method Detail

start

public void start()
           throws IOException

Throws:

IOException

doesNamespaceExist

public boolean doesNamespaceExist(String namespaceName)
                           throws IOException

Throws:

IOException

get

public NamespaceDescriptor get(String name)
                        throws IOException

Throws:

IOException

insertIntoNSTable

public void insertIntoNSTable(NamespaceDescriptor ns)
                       throws IOException

Throws:

IOException

updateZKNamespaceManager

public void updateZKNamespaceManager(NamespaceDescriptor ns)
                              throws IOException

Throws:

IOException

removeFromNSTable

public void removeFromNSTable(String namespaceName)
                       throws IOException

Throws:

IOException

removeFromZKNamespaceManager

public void removeFromZKNamespaceManager(String namespaceName)
                                  throws IOException

Throws:

IOException

list

public NavigableSet<NamespaceDescriptor> list()
                                       throws IOException

Throws:

IOException

isTableAvailableAndInitialized

public boolean isTableAvailableAndInitialized()
                                       throws 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:

IOException

validateTableAndRegionCount

public void validateTableAndRegionCount(NamespaceDescriptor desc)
                                 throws IOException

Throws:

IOException

getMaxTables

public static long getMaxTables(NamespaceDescriptor ns)
                         throws IOException

Throws:

IOException

getMaxRegions

public static long getMaxRegions(NamespaceDescriptor ns)
                          throws IOException

Throws:

IOException

isStopped

public boolean isStopped()

Specified by:

isStopped in interface Stoppable

Returns:

True if Stoppable.stop(String) has been closed.

stop

public void stop(String why)

Description copied from interface: Stoppable

Stop this service. Implementers should favor logging errors over throwing RuntimeExceptions.

Specified by:

stop in interface Stoppable

Parameters:

why - Why we're stopping.