Package org.apache.hadoop.hbase.master

Class TableNamespaceManager

java.lang.Object

org.apache.hadoop.hbase.master.TableNamespaceManager

All Implemented Interfaces:

Stoppable

@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	Description
private org.apache.hadoop.conf.Configuration	conf
(package private) static final int	DEFAULT_NS_INIT_TIMEOUT
private boolean	initialized
static final String	KEY_MAX_REGIONS
static final String	KEY_MAX_TABLES
private static final org.slf4j.Logger	LOG
private MasterServices	masterServices
(package private) static final String	NS_INIT_TIMEOUT
private Table	nsTable
private boolean	stopped
private ZKNamespaceManager	zkNamespaceManager

Constructor Summary

Constructors

Constructor	Description
TableNamespaceManager(MasterServices masterServices)

Method Summary

Modifier and Type	Method	Description
private static void	block(MasterServices services, long procId)	An ugly utility to be removed when refactor TableNamespaceManager.
private void	blockingCreateNamespace(NamespaceDescriptor namespaceDescriptor)	Create Namespace in a blocking manner.
private void	createNamespaceTable(MasterServices masterServices)
boolean	doesNamespaceExist(String namespaceName)
NamespaceDescriptor	get(String name)
private NamespaceDescriptor	get(Table table, String name)
static long	getMaxRegions(NamespaceDescriptor ns)
static long	getMaxTables(NamespaceDescriptor ns)
private Table	getNamespaceTable()
private TableState	getTableState()
void	insertIntoNSTable(NamespaceDescriptor ns)
boolean	isStopped()	Returns True if Stoppable.stop(String) has been closed.
private boolean	isTableAssigned()
boolean	isTableAvailableAndInitialized()	This method checks if the namespace table is assigned and then tries to create its Table reference.
private boolean	isTableEnabled()
private boolean	isTableNamespaceManagerInitialized()
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 Details

LOG

private static final org.slf4j.Logger LOG

stopped

private volatile boolean stopped

conf

private org.apache.hadoop.conf.Configuration conf

masterServices

private MasterServices masterServices

nsTable

private Table nsTable

zkNamespaceManager

private ZKNamespaceManager zkNamespaceManager

initialized

private boolean initialized

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

NS_INIT_TIMEOUT

static final String NS_INIT_TIMEOUT

See Also:

• Constant Field Values

DEFAULT_NS_INIT_TIMEOUT

static final int DEFAULT_NS_INIT_TIMEOUT

See Also:

• Constant Field Values

Constructor Details

TableNamespaceManager

TableNamespaceManager(MasterServices masterServices)

Method Details

start

public void start()
           throws IOException

Throws:

IOException

getNamespaceTable

private Table getNamespaceTable()
                         throws IOException

Throws:

IOException

doesNamespaceExist

public boolean doesNamespaceExist(String namespaceName)
                           throws IOException

Throws:

IOException

get

public NamespaceDescriptor get(String name)
                        throws IOException

Throws:

IOException

get

private NamespaceDescriptor get(Table table,
 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

createNamespaceTable

private void createNamespaceTable(MasterServices masterServices)
                           throws IOException

Throws:

IOException

isTableNamespaceManagerInitialized

private boolean isTableNamespaceManagerInitialized()
                                            throws IOException

Throws:

IOException

blockingCreateNamespace

private void blockingCreateNamespace(NamespaceDescriptor namespaceDescriptor)
                              throws IOException

Create Namespace in a blocking manner. Keeps trying until ClusterSchema.HBASE_MASTER_CLUSTER_SCHEMA_OPERATION_TIMEOUT_KEY expires. Note, by-passes notifying coprocessors and name checks. Use for system namespaces only.

Throws:

IOException

block

private static void block(MasterServices services,
 long procId)
                   throws TimeoutIOException

An ugly utility to be removed when refactor TableNamespaceManager.

Throws:

TimeoutIOException

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

getTableState

private TableState getTableState()
                          throws IOException

Throws:

IOException

isTableEnabled

private boolean isTableEnabled()
                        throws IOException

Throws:

IOException

isTableAssigned

private boolean isTableAssigned()

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()

Description copied from interface: Stoppable

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

Specified by:

isStopped in interface Stoppable

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.