@InterfaceAudience.Private public class TableStateManager extends Object
Modifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOG |
private MasterServices |
master |
private ConcurrentMap<TableName,TableState.State> |
tableName2State |
private IdReadWriteLock<TableName> |
tnLock |
Constructor and Description |
---|
TableStateManager(MasterServices master) |
Modifier and Type | Method and Description |
---|---|
(package private) 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) |
private TableState |
readMetaState(TableName tableName) |
void |
setDeletedTable(TableName tableName) |
void |
setTableState(TableName tableName,
TableState.State newState)
Set table state to provided.
|
private void |
updateMetaState(TableName tableName,
TableState.State newState) |
private static final org.slf4j.Logger LOG
private final IdReadWriteLock<TableName> tnLock
private final MasterServices master
private final ConcurrentMap<TableName,TableState.State> tableName2State
TableStateManager(MasterServices master)
public void setTableState(TableName tableName, TableState.State newState) throws IOException
tableName
- table to change state fornewState
- new stateIOException
public boolean isTableState(TableName tableName, TableState.State... states)
public void setDeletedTable(TableName tableName) throws IOException
IOException
public boolean isTablePresent(TableName tableName) throws IOException
IOException
Set<TableName> getTablesInStates(TableState.State... states) throws IOException
states
- filter by statesIOException
@NonNull public TableState getTableState(TableName tableName) throws IOException
IOException
private void updateMetaState(TableName tableName, TableState.State newState) throws IOException
IOException
@Nullable private TableState readMetaState(TableName tableName) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.