public class DeleteNamespaceProcedure extends AbstractStateMachineNamespaceProcedure<DeleteNamespaceState>
TableProcedureInterface.TableOperationType
Constructor and Description |
---|
DeleteNamespaceProcedure() |
DeleteNamespaceProcedure(MasterProcedureEnv env,
java.lang.String namespaceName) |
DeleteNamespaceProcedure(MasterProcedureEnv env,
java.lang.String namespaceName,
ProcedurePrepareLatch latch) |
Modifier and Type | Method and Description |
---|---|
protected static void |
deleteDirectory(MasterProcedureEnv env,
java.lang.String namespaceName)
Delete the namespace directories from the file system
|
protected static void |
deleteFromNSTable(MasterProcedureEnv env,
java.lang.String namespaceName)
delete the row from namespace table
|
protected void |
deserializeStateData(ProcedureStateSerializer serializer) |
protected Flow |
executeFromState(MasterProcedureEnv env,
DeleteNamespaceState state) |
protected DeleteNamespaceState |
getInitialState() |
protected java.lang.String |
getNamespaceName() |
protected DeleteNamespaceState |
getState(int stateId) |
protected int |
getStateId(DeleteNamespaceState state) |
TableProcedureInterface.TableOperationType |
getTableOperationType()
Given an operation type we can take decisions about what to do with pending operations.
|
protected boolean |
isRollbackSupported(DeleteNamespaceState state) |
protected static void |
removeFromZKNamespaceManager(MasterProcedureEnv env,
java.lang.String namespaceName)
remove from ZooKeeper.
|
protected static void |
removeNamespaceQuota(MasterProcedureEnv env,
java.lang.String namespaceName)
remove quota for the namespace
|
protected void |
rollbackState(MasterProcedureEnv env,
DeleteNamespaceState state) |
protected void |
serializeStateData(ProcedureStateSerializer serializer) |
acquireLock, getTableName, releaseLock, releaseSyncLatch, toStringClassDetails
public DeleteNamespaceProcedure()
public DeleteNamespaceProcedure(MasterProcedureEnv env, java.lang.String namespaceName)
public DeleteNamespaceProcedure(MasterProcedureEnv env, java.lang.String namespaceName, ProcedurePrepareLatch latch)
protected Flow executeFromState(MasterProcedureEnv env, DeleteNamespaceState state) throws java.lang.InterruptedException
java.lang.InterruptedException
protected void rollbackState(MasterProcedureEnv env, DeleteNamespaceState state) throws java.io.IOException
java.io.IOException
protected boolean isRollbackSupported(DeleteNamespaceState state)
protected DeleteNamespaceState getState(int stateId)
protected int getStateId(DeleteNamespaceState state)
protected DeleteNamespaceState 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 TableProcedureInterface.TableOperationType getTableOperationType()
TableProcedureInterface
getTableOperationType
in interface TableProcedureInterface
getTableOperationType
in class AbstractStateMachineNamespaceProcedure<DeleteNamespaceState>
protected java.lang.String getNamespaceName()
getNamespaceName
in class AbstractStateMachineNamespaceProcedure<DeleteNamespaceState>
protected static void deleteFromNSTable(MasterProcedureEnv env, java.lang.String namespaceName) throws java.io.IOException
env
- MasterProcedureEnvnamespaceName
- name of the namespace in string formatjava.io.IOException
protected static void removeFromZKNamespaceManager(MasterProcedureEnv env, java.lang.String namespaceName) throws java.io.IOException
env
- MasterProcedureEnvnamespaceName
- name of the namespace in string formatjava.io.IOException
protected static void deleteDirectory(MasterProcedureEnv env, java.lang.String namespaceName) throws java.io.IOException
env
- MasterProcedureEnvnamespaceName
- name of the namespace in string formatjava.io.IOException
protected static void removeNamespaceQuota(MasterProcedureEnv env, java.lang.String namespaceName) throws java.io.IOException
env
- MasterProcedureEnvnamespaceName
- name of the namespace in string formatjava.io.IOException