public class EnableTableProcedure extends AbstractStateMachineTableProcedure<EnableTableState>
TableProcedureInterface.TableOperationType
Constructor and Description |
---|
EnableTableProcedure() |
EnableTableProcedure(MasterProcedureEnv env,
TableName tableName,
boolean skipTableStateCheck)
Constructor
|
EnableTableProcedure(MasterProcedureEnv env,
TableName tableName,
boolean skipTableStateCheck,
ProcedurePrepareLatch syncLatch)
Constructor
|
Modifier and Type | Method and Description |
---|---|
protected void |
deserializeStateData(ProcedureStateSerializer serializer) |
protected Flow |
executeFromState(MasterProcedureEnv env,
EnableTableState state) |
protected EnableTableState |
getInitialState() |
protected EnableTableState |
getState(int stateId) |
protected int |
getStateId(EnableTableState state) |
TableName |
getTableName() |
TableProcedureInterface.TableOperationType |
getTableOperationType()
Given an operation type we can take decisions about what to do with pending operations.
|
protected boolean |
isRollbackSupported(EnableTableState state) |
protected void |
rollbackState(MasterProcedureEnv env,
EnableTableState state) |
protected void |
serializeStateData(ProcedureStateSerializer serializer) |
protected static void |
setTableStateToEnabled(MasterProcedureEnv env,
TableName tableName)
Mark table state to Enabled
|
protected static void |
setTableStateToEnabling(MasterProcedureEnv env,
TableName tableName)
Mark table state to Enabling
|
acquireLock, checkOnline, checkTableModifiable, getRegionDir, getUser, preflightChecks, releaseLock, releaseSyncLatch, setUser, toStringClassDetails
public EnableTableProcedure()
public EnableTableProcedure(MasterProcedureEnv env, TableName tableName, boolean skipTableStateCheck)
env
- MasterProcedureEnvtableName
- the table to operate onskipTableStateCheck
- whether to check table statepublic EnableTableProcedure(MasterProcedureEnv env, TableName tableName, boolean skipTableStateCheck, ProcedurePrepareLatch syncLatch)
env
- MasterProcedureEnvtableName
- the table to operate onskipTableStateCheck
- whether to check table stateprotected Flow executeFromState(MasterProcedureEnv env, EnableTableState state) throws java.lang.InterruptedException
java.lang.InterruptedException
protected void rollbackState(MasterProcedureEnv env, EnableTableState state) throws java.io.IOException
java.io.IOException
protected boolean isRollbackSupported(EnableTableState state)
protected EnableTableState getState(int stateId)
protected int getStateId(EnableTableState state)
protected EnableTableState getInitialState()
protected void serializeStateData(ProcedureStateSerializer serializer) throws java.io.IOException
java.io.IOException
protected void deserializeStateData(ProcedureStateSerializer serializer) throws java.io.IOException
java.io.IOException
public TableName getTableName()
getTableName
in interface TableProcedureInterface
getTableName
in class AbstractStateMachineTableProcedure<EnableTableState>
public TableProcedureInterface.TableOperationType getTableOperationType()
TableProcedureInterface
getTableOperationType
in interface TableProcedureInterface
getTableOperationType
in class AbstractStateMachineTableProcedure<EnableTableState>
protected static void setTableStateToEnabling(MasterProcedureEnv env, TableName tableName) throws java.io.IOException
env
- MasterProcedureEnvtableName
- the target tablejava.io.IOException
protected static void setTableStateToEnabled(MasterProcedureEnv env, TableName tableName) throws java.io.IOException
env
- MasterProcedureEnvjava.io.IOException