@InterfaceAudience.Private public class TableStateManager extends Object
start()
is called.Modifier and Type | Class and Description |
---|---|
static class |
TableStateManager.TableStateNotFoundException |
Modifier and Type | Field and Description |
---|---|
protected MasterServices |
master |
Constructor and Description |
---|
TableStateManager(MasterServices master) |
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.
|
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) |
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() |
protected final MasterServices master
public TableStateManager(MasterServices master)
public void setTableState(TableName tableName, TableState.State newState) throws IOException
tableName
- table to change state fornewState
- new stateIOException
public TableState setTableStateIfInStates(TableName tableName, TableState.State newState, TableState.State... states) throws IOException
tableName
- table to change state fornewState
- new statestates
- states to check againstIOException
public boolean setTableStateIfNotInStates(TableName tableName, TableState.State newState, TableState.State... states) throws IOException
tableName
- table to change state fornewState
- new statestates
- states to check againstIOException
public boolean isTableState(TableName tableName, TableState.State... states)
public void setDeletedTable(TableName tableName) throws IOException
IOException
public boolean isTablePresent(TableName tableName) throws IOException
IOException
public Set<TableName> getTablesInStates(TableState.State... states) throws IOException
states
- filter by statesIOException
@NonNull public TableState getTableState(TableName tableName) throws IOException
IOException
protected void metaStateUpdated(TableName tableName, TableState.State newState) throws IOException
IOException
protected void metaStateDeleted(TableName tableName) throws IOException
IOException
public void start() throws IOException
IOException
protected void fixTableState(TableState tableState) throws IOException
IOException
@Deprecated protected void deleteZooKeeper(TableName tableName)
Copyright © 2007–2019 Cloudera. All rights reserved.