public class CreateNamespaceProcedure extends AbstractStateMachineNamespaceProcedure<CreateNamespaceState>
TableProcedureInterface.TableOperationType
Constructor and Description |
---|
CreateNamespaceProcedure() |
CreateNamespaceProcedure(MasterProcedureEnv env,
NamespaceDescriptor nsDescriptor) |
CreateNamespaceProcedure(MasterProcedureEnv env,
NamespaceDescriptor nsDescriptor,
ProcedurePrepareLatch latch) |
Modifier and Type | Method and Description |
---|---|
protected LockState |
acquireLock(MasterProcedureEnv env) |
protected static void |
createDirectory(MasterProcedureEnv env,
NamespaceDescriptor nsDescriptor)
Create the namespace directory
|
protected void |
deserializeStateData(ProcedureStateSerializer serializer) |
protected Flow |
executeFromState(MasterProcedureEnv env,
CreateNamespaceState state) |
protected CreateNamespaceState |
getInitialState() |
protected java.lang.String |
getNamespaceName() |
protected CreateNamespaceState |
getState(int stateId) |
protected int |
getStateId(CreateNamespaceState state) |
TableProcedureInterface.TableOperationType |
getTableOperationType()
Given an operation type we can take decisions about what to do with pending operations.
|
protected static void |
insertIntoNSTable(MasterProcedureEnv env,
NamespaceDescriptor nsDescriptor)
Insert the row into ns table
|
protected boolean |
isRollbackSupported(CreateNamespaceState state) |
protected void |
rollbackState(MasterProcedureEnv env,
CreateNamespaceState state) |
protected void |
serializeStateData(ProcedureStateSerializer serializer) |
protected static void |
setNamespaceQuota(MasterProcedureEnv env,
NamespaceDescriptor nsDescriptor)
Set quota for the namespace
|
protected boolean |
shouldWaitClientAck(MasterProcedureEnv env) |
protected static void |
updateZKNamespaceManager(MasterProcedureEnv env,
NamespaceDescriptor nsDescriptor)
Update ZooKeeper.
|
getTableName, releaseLock, releaseSyncLatch, toStringClassDetails
public CreateNamespaceProcedure()
public CreateNamespaceProcedure(MasterProcedureEnv env, NamespaceDescriptor nsDescriptor)
public CreateNamespaceProcedure(MasterProcedureEnv env, NamespaceDescriptor nsDescriptor, ProcedurePrepareLatch latch)
protected Flow executeFromState(MasterProcedureEnv env, CreateNamespaceState state) throws java.lang.InterruptedException
java.lang.InterruptedException
protected void rollbackState(MasterProcedureEnv env, CreateNamespaceState state) throws java.io.IOException
java.io.IOException
protected boolean isRollbackSupported(CreateNamespaceState state)
protected CreateNamespaceState getState(int stateId)
protected int getStateId(CreateNamespaceState state)
protected CreateNamespaceState 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
protected LockState acquireLock(MasterProcedureEnv env)
acquireLock
in class AbstractStateMachineNamespaceProcedure<CreateNamespaceState>
public TableProcedureInterface.TableOperationType getTableOperationType()
TableProcedureInterface
getTableOperationType
in interface TableProcedureInterface
getTableOperationType
in class AbstractStateMachineNamespaceProcedure<CreateNamespaceState>
protected java.lang.String getNamespaceName()
getNamespaceName
in class AbstractStateMachineNamespaceProcedure<CreateNamespaceState>
protected static void createDirectory(MasterProcedureEnv env, NamespaceDescriptor nsDescriptor) throws java.io.IOException
env
- MasterProcedureEnvnsDescriptor
- NamespaceDescriptorjava.io.IOException
protected static void insertIntoNSTable(MasterProcedureEnv env, NamespaceDescriptor nsDescriptor) throws java.io.IOException
env
- MasterProcedureEnvnsDescriptor
- NamespaceDescriptorjava.io.IOException
protected static void updateZKNamespaceManager(MasterProcedureEnv env, NamespaceDescriptor nsDescriptor) throws java.io.IOException
env
- MasterProcedureEnvnsDescriptor
- NamespaceDescriptorjava.io.IOException
protected static void setNamespaceQuota(MasterProcedureEnv env, NamespaceDescriptor nsDescriptor) throws java.io.IOException
env
- MasterProcedureEnvnsDescriptor
- NamespaceDescriptorjava.io.IOException
protected boolean shouldWaitClientAck(MasterProcedureEnv env)