public class DeleteTableProcedure extends AbstractStateMachineTableProcedure<DeleteTableState>
TableProcedureInterface.TableOperationType
Constructor and Description |
---|
DeleteTableProcedure() |
DeleteTableProcedure(MasterProcedureEnv env,
TableName tableName) |
DeleteTableProcedure(MasterProcedureEnv env,
TableName tableName,
ProcedurePrepareLatch syncLatch) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
abort(MasterProcedureEnv env) |
protected static void |
deleteAssignmentState(MasterProcedureEnv env,
TableName tableName) |
protected static void |
deleteFromFs(MasterProcedureEnv env,
TableName tableName,
java.util.List<RegionInfo> regions,
boolean archive) |
protected static void |
deleteFromMeta(MasterProcedureEnv env,
TableName tableName,
java.util.List<RegionInfo> regions) |
protected static void |
deleteTableDescriptorCache(MasterProcedureEnv env,
TableName tableName) |
protected static void |
deleteTableStates(MasterProcedureEnv env,
TableName tableName) |
protected void |
deserializeStateData(ProcedureStateSerializer serializer) |
protected Flow |
executeFromState(MasterProcedureEnv env,
DeleteTableState state) |
protected DeleteTableState |
getInitialState() |
protected DeleteTableState |
getState(int stateId) |
protected int |
getStateId(DeleteTableState state) |
TableName |
getTableName() |
TableProcedureInterface.TableOperationType |
getTableOperationType()
Given an operation type we can take decisions about what to do with pending operations.
|
protected boolean |
isRollbackSupported(DeleteTableState state) |
protected void |
rollbackState(MasterProcedureEnv env,
DeleteTableState state) |
protected void |
serializeStateData(ProcedureStateSerializer serializer) |
acquireLock, checkOnline, checkTableModifiable, getRegionDir, getUser, preflightChecks, releaseLock, releaseSyncLatch, setUser, toStringClassDetails
public DeleteTableProcedure()
public DeleteTableProcedure(MasterProcedureEnv env, TableName tableName)
public DeleteTableProcedure(MasterProcedureEnv env, TableName tableName, ProcedurePrepareLatch syncLatch)
protected Flow executeFromState(MasterProcedureEnv env, DeleteTableState state) throws java.lang.InterruptedException
java.lang.InterruptedException
protected boolean abort(MasterProcedureEnv env)
protected void rollbackState(MasterProcedureEnv env, DeleteTableState state)
protected boolean isRollbackSupported(DeleteTableState state)
protected DeleteTableState getState(int stateId)
protected int getStateId(DeleteTableState state)
protected DeleteTableState getInitialState()
public TableName getTableName()
getTableName
in interface TableProcedureInterface
getTableName
in class AbstractStateMachineTableProcedure<DeleteTableState>
public TableProcedureInterface.TableOperationType getTableOperationType()
TableProcedureInterface
getTableOperationType
in interface TableProcedureInterface
getTableOperationType
in class AbstractStateMachineTableProcedure<DeleteTableState>
protected void serializeStateData(ProcedureStateSerializer serializer) throws java.io.IOException
java.io.IOException
protected void deserializeStateData(ProcedureStateSerializer serializer) throws java.io.IOException
java.io.IOException
protected static void deleteFromFs(MasterProcedureEnv env, TableName tableName, java.util.List<RegionInfo> regions, boolean archive) throws java.io.IOException
java.io.IOException
protected static void deleteFromMeta(MasterProcedureEnv env, TableName tableName, java.util.List<RegionInfo> regions) throws java.io.IOException
java.io.IOException
protected static void deleteAssignmentState(MasterProcedureEnv env, TableName tableName) throws java.io.IOException
java.io.IOException
protected static void deleteTableDescriptorCache(MasterProcedureEnv env, TableName tableName) throws java.io.IOException
java.io.IOException
protected static void deleteTableStates(MasterProcedureEnv env, TableName tableName) throws java.io.IOException
java.io.IOException