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, toStringClassDetailspublic 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.InterruptedExceptionprotected void rollbackState(MasterProcedureEnv env, DeleteNamespaceState state) throws java.io.IOException
java.io.IOExceptionprotected 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.IOExceptionprotected void deserializeStateData(ProcedureStateSerializer serializer)
throws java.io.IOException
java.io.IOExceptionpublic TableProcedureInterface.TableOperationType getTableOperationType()
TableProcedureInterfacegetTableOperationType in interface TableProcedureInterfacegetTableOperationType 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.IOExceptionprotected static void removeFromZKNamespaceManager(MasterProcedureEnv env, java.lang.String namespaceName) throws java.io.IOException
env - MasterProcedureEnvnamespaceName - name of the namespace in string formatjava.io.IOExceptionprotected static void deleteDirectory(MasterProcedureEnv env, java.lang.String namespaceName) throws java.io.IOException
env - MasterProcedureEnvnamespaceName - name of the namespace in string formatjava.io.IOExceptionprotected static void removeNamespaceQuota(MasterProcedureEnv env, java.lang.String namespaceName) throws java.io.IOException
env - MasterProcedureEnvnamespaceName - name of the namespace in string formatjava.io.IOException