org.apache.hadoop.hbase.master

Class TableStateManager

java.lang.Object

org.apache.hadoop.hbase.master.TableStateManager

Direct Known Subclasses:

MirroringTableStateManager

@InterfaceAudience.Private
public class TableStateManager
extends Object

This is a helper class used to manage table states. This class uses hbase:meta as its store for table state so hbase:meta must be online before start() is called.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TableStateManager.TableStateNotFoundException

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG
protected MasterServices	master
private static String	MIGRATE_TABLE_STATE_FROM_ZK_KEY Set this key to false in Configuration to disable migrating table state from zookeeper so hbase:meta table.
private ConcurrentMap<TableName,TableState.State>	tableName2State
private IdReadWriteLock<TableName>	tnLock

Constructor Summary

Constructors

Constructor and Description
TableStateManager(MasterServices master)

Method Summary

Modifier and Type	Method and Description
protected void	deleteZooKeeper(TableName tableName) Deprecated. Since 2.0.0. To be removed in hbase-3.0.0.
protected void	fixTableState(TableState tableState) For subclasses in case they want to do fixup post hbase:meta.
private void	fixTableStates(TableDescriptors tableDescriptors, Connection connection)
Set<TableName>	getTablesInStates(TableState.State... states) Return all tables in given states.
TableState	getTableState(TableName tableName)
boolean	isTablePresent(TableName tableName)
boolean	isTableState(TableName tableName, TableState.State... states)
protected void	metaStateDeleted(TableName tableName)
protected void	metaStateUpdated(TableName tableName, TableState.State newState)
private void	migrateZooKeeper() Deprecated. Since 2.0.0. Remove in hbase-3.0.0.
private TableState	readMetaState(TableName tableName)
void	setDeletedTable(TableName tableName)
void	setTableState(TableName tableName, TableState.State newState) Set table state to provided.
TableState	setTableStateIfInStates(TableName tableName, TableState.State newState, TableState.State... states) Set table state to provided but only if table in specified states Caller should lock table on write.
boolean	setTableStateIfNotInStates(TableName tableName, TableState.State newState, TableState.State... states) Set table state to provided but only if table not in specified states Caller should lock table on write.
void	start()
private void	updateMetaState(TableName tableName, TableState.State newState)

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

MIGRATE_TABLE_STATE_FROM_ZK_KEY

private static final String MIGRATE_TABLE_STATE_FROM_ZK_KEY

Set this key to false in Configuration to disable migrating table state from zookeeper so hbase:meta table.

See Also:

Constant Field Values

tnLock

private final IdReadWriteLock<TableName> tnLock

master

protected final MasterServices master

tableName2State

private final ConcurrentMap<TableName,TableState.State> tableName2State

Constructor Detail

TableStateManager

public TableStateManager(MasterServices master)

Method Detail

setTableState

public void setTableState(TableName tableName,
                          TableState.State newState)
                   throws IOException

Set table state to provided. Caller should lock table on write.

Parameters:

tableName - table to change state for

newState - new state

Throws:

IOException

setTableStateIfInStates

public TableState setTableStateIfInStates(TableName tableName,
                                          TableState.State newState,
                                          TableState.State... states)
                                   throws IOException

Set table state to provided but only if table in specified states Caller should lock table on write.

Parameters:

tableName - table to change state for

newState - new state

states - states to check against

Returns:

null if succeed or table state if failed

Throws:

IOException

setTableStateIfNotInStates

public boolean setTableStateIfNotInStates(TableName tableName,
                                          TableState.State newState,
                                          TableState.State... states)
                                   throws IOException

Set table state to provided but only if table not in specified states Caller should lock table on write.

Parameters:

tableName - table to change state for

newState - new state

states - states to check against

Throws:

IOException

isTableState

public boolean isTableState(TableName tableName,
                            TableState.State... states)

setDeletedTable

public void setDeletedTable(TableName tableName)
                     throws IOException

Throws:

IOException

isTablePresent

public boolean isTablePresent(TableName tableName)
                       throws IOException

Throws:

IOException

getTablesInStates

public Set<TableName> getTablesInStates(TableState.State... states)
                                 throws IOException

Return all tables in given states.

Parameters:

states - filter by states

Returns:

tables in given states

Throws:

IOException

getTableState

@NonNull
public TableState getTableState(TableName tableName)
                                  throws IOException

Throws:

IOException

updateMetaState

private void updateMetaState(TableName tableName,
                             TableState.State newState)
                      throws IOException

Throws:

IOException

metaStateUpdated

protected void metaStateUpdated(TableName tableName,
                                TableState.State newState)
                         throws IOException

Throws:

IOException

metaStateDeleted

protected void metaStateDeleted(TableName tableName)
                         throws IOException

Throws:

IOException

readMetaState

@Nullable
private TableState readMetaState(TableName tableName)
                                    throws IOException

Throws:

IOException

start

public void start()
           throws IOException

Throws:

IOException

fixTableStates

private void fixTableStates(TableDescriptors tableDescriptors,
                            Connection connection)
                     throws IOException

Throws:

IOException

fixTableState

protected void fixTableState(TableState tableState)
                      throws IOException

For subclasses in case they want to do fixup post hbase:meta.

Throws:

IOException

migrateZooKeeper

@Deprecated
private void migrateZooKeeper()
                                   throws IOException

Deprecated. Since 2.0.0. Remove in hbase-3.0.0.

This code is for case where a hbase2 Master is starting for the first time. ZooKeeper is where we used to keep table state. On first startup, read zookeeper and update hbase:meta with the table states found in zookeeper. This is tricky as we'll do this check every time we startup until mirroring is disabled. See the MIGRATE_TABLE_STATE_FROM_ZK_KEY flag. Original form of this migration came in with HBASE-13032. It deleted all znodes when done. We can't do that if we want to support hbase-1.x clients who need to be able to read table state out of zk. See MirroringTableStateManager.

Throws:

IOException

deleteZooKeeper

@Deprecated
protected void deleteZooKeeper(TableName tableName)

Deprecated. Since 2.0.0. To be removed in hbase-3.0.0.

Utility method that knows how to delete the old hbase-1.x table state znode. Used also by the Mirroring subclass.