@InterfaceAudience.Private public class CreateTableProcedure extends StateMachineProcedure<MasterProcedureEnv,MasterProcedureProtos.CreateTableState> implements TableProcedureInterface
Modifier and Type | Class and Description |
---|---|
protected static interface |
CreateTableProcedure.CreateHdfsRegions |
StateMachineProcedure.Flow
TableProcedureInterface.TableOperationType
Constructor and Description |
---|
CreateTableProcedure() |
CreateTableProcedure(MasterProcedureEnv env,
HTableDescriptor hTableDescriptor,
HRegionInfo[] newRegions) |
CreateTableProcedure(MasterProcedureEnv env,
HTableDescriptor hTableDescriptor,
HRegionInfo[] newRegions,
ProcedurePrepareLatch syncLatch) |
Modifier and Type | Method and Description |
---|---|
boolean |
abort(MasterProcedureEnv env)
The abort() call is asynchronous and each procedure must decide how to deal
with that, if they want to be abortable.
|
protected boolean |
acquireLock(MasterProcedureEnv env)
The user should override this method, and try to take a lock if necessary.
|
protected static void |
addRegionsToMeta(MasterProcedureEnv env,
HTableDescriptor hTableDescriptor,
java.util.List<HRegionInfo> regionInfos)
Add the specified set of regions to the hbase:meta table.
|
protected static java.util.List<HRegionInfo> |
addTableToMeta(MasterProcedureEnv env,
HTableDescriptor hTableDescriptor,
java.util.List<HRegionInfo> regions) |
protected static void |
assignRegions(MasterProcedureEnv env,
TableName tableName,
java.util.List<HRegionInfo> regions) |
protected static java.util.List<HRegionInfo> |
createFsLayout(MasterProcedureEnv env,
HTableDescriptor hTableDescriptor,
java.util.List<HRegionInfo> newRegions) |
protected static java.util.List<HRegionInfo> |
createFsLayout(MasterProcedureEnv env,
HTableDescriptor hTableDescriptor,
java.util.List<HRegionInfo> newRegions,
CreateTableProcedure.CreateHdfsRegions hdfsRegionHandler) |
void |
deserializeStateData(java.io.InputStream stream)
Called on store load to allow the user to decode the previously serialized
state.
|
protected StateMachineProcedure.Flow |
executeFromState(MasterProcedureEnv env,
MasterProcedureProtos.CreateTableState state)
called to perform a single step of the specified 'state' of the procedure
|
protected MasterProcedureProtos.CreateTableState |
getInitialState()
Return the initial state object that will be used for the first call to executeFromState().
|
protected MasterProcedureProtos.CreateTableState |
getState(int stateId)
Convert an ordinal (or state id) to an Enum (or more descriptive) state object.
|
protected int |
getStateId(MasterProcedureProtos.CreateTableState state)
Convert the Enum (or more descriptive) state object to an ordinal (or state id).
|
TableName |
getTableName() |
TableProcedureInterface.TableOperationType |
getTableOperationType()
Given an operation type we can take decisions about what to do with pending operations.
|
protected void |
releaseLock(MasterProcedureEnv env)
The user should override this method, and release lock if necessary.
|
protected void |
rollbackState(MasterProcedureEnv env,
MasterProcedureProtos.CreateTableState state)
called to perform the rollback of the specified state
|
void |
serializeStateData(java.io.OutputStream stream)
The user-level code of the procedure may have some state to
persist (e.g.
|
protected void |
setNextState(MasterProcedureProtos.CreateTableState state)
Set the next state for the procedure.
|
void |
toStringClassDetails(java.lang.StringBuilder sb)
Extend the toString() information with the procedure details
e.g.
|
protected static void |
updateTableDescCache(MasterProcedureEnv env,
TableName tableName) |
execute, rollback
addStackIndex, beforeReplay, childrenCountDown, compareTo, completionCleanup, convert, convert, createProcedureInfo, doExecute, doRollback, elapsedTime, getException, getLastUpdate, getNonceKey, getOwner, getParentProcId, getProcId, getResult, getRootProcedureId, getStackIndexes, getStartTime, getState, getTimeout, getTimeRemaining, hasException, hasOwner, hasParent, hasTimeout, incChildrenLatch, isFailed, isFinished, isSuccess, isWaiting, newInstance, removeStackIndex, setAbortFailure, setChildrenLatch, setFailure, setFailure, setNonceKey, setOwner, setParentProcId, setProcId, setResult, setStackIndexes, setStartTime, setState, setTimeout, setTimeoutFailure, toString, toStringClass, toStringDetails, toStringSimpleSB, updateTimestamp, validateClass, wasExecuted
public CreateTableProcedure()
public CreateTableProcedure(MasterProcedureEnv env, HTableDescriptor hTableDescriptor, HRegionInfo[] newRegions) throws java.io.IOException
java.io.IOException
public CreateTableProcedure(MasterProcedureEnv env, HTableDescriptor hTableDescriptor, HRegionInfo[] newRegions, ProcedurePrepareLatch syncLatch) throws java.io.IOException
java.io.IOException
protected StateMachineProcedure.Flow executeFromState(MasterProcedureEnv env, MasterProcedureProtos.CreateTableState state)
StateMachineProcedure
executeFromState
in class StateMachineProcedure<MasterProcedureEnv,MasterProcedureProtos.CreateTableState>
state
- state to executeprotected void rollbackState(MasterProcedureEnv env, MasterProcedureProtos.CreateTableState state) throws java.io.IOException
StateMachineProcedure
rollbackState
in class StateMachineProcedure<MasterProcedureEnv,MasterProcedureProtos.CreateTableState>
state
- state to rollbackjava.io.IOException
- temporary failure, the rollback will retry laterprotected MasterProcedureProtos.CreateTableState getState(int stateId)
StateMachineProcedure
getState
in class StateMachineProcedure<MasterProcedureEnv,MasterProcedureProtos.CreateTableState>
stateId
- the ordinal() of the state enum (or state id)protected int getStateId(MasterProcedureProtos.CreateTableState state)
StateMachineProcedure
getStateId
in class StateMachineProcedure<MasterProcedureEnv,MasterProcedureProtos.CreateTableState>
state
- the state enum objectprotected MasterProcedureProtos.CreateTableState getInitialState()
StateMachineProcedure
getInitialState
in class StateMachineProcedure<MasterProcedureEnv,MasterProcedureProtos.CreateTableState>
protected void setNextState(MasterProcedureProtos.CreateTableState state)
StateMachineProcedure
setNextState
in class StateMachineProcedure<MasterProcedureEnv,MasterProcedureProtos.CreateTableState>
state
- the state enum objectpublic TableName getTableName()
getTableName
in interface TableProcedureInterface
public TableProcedureInterface.TableOperationType getTableOperationType()
TableProcedureInterface
getTableOperationType
in interface TableProcedureInterface
public boolean abort(MasterProcedureEnv env)
Procedure
abort
in class Procedure<MasterProcedureEnv>
env
- the environment passed to the ProcedureExecutorpublic void toStringClassDetails(java.lang.StringBuilder sb)
Procedure
toStringClassDetails
in class Procedure<MasterProcedureEnv>
sb
- the string builder to use to append the proc specific informationpublic void serializeStateData(java.io.OutputStream stream) throws java.io.IOException
Procedure
serializeStateData
in class StateMachineProcedure<MasterProcedureEnv,MasterProcedureProtos.CreateTableState>
stream
- the stream that will contain the user serialized datajava.io.IOException
- failure to stream datapublic void deserializeStateData(java.io.InputStream stream) throws java.io.IOException
Procedure
deserializeStateData
in class StateMachineProcedure<MasterProcedureEnv,MasterProcedureProtos.CreateTableState>
stream
- the stream that contains the user serialized datajava.io.IOException
protected boolean acquireLock(MasterProcedureEnv env)
Procedure
acquireLock
in class Procedure<MasterProcedureEnv>
env
- the environment passed to the ProcedureExecutorprotected void releaseLock(MasterProcedureEnv env)
Procedure
releaseLock
in class Procedure<MasterProcedureEnv>
env
- the environment passed to the ProcedureExecutorprotected static java.util.List<HRegionInfo> createFsLayout(MasterProcedureEnv env, HTableDescriptor hTableDescriptor, java.util.List<HRegionInfo> newRegions) throws java.io.IOException
java.io.IOException
protected static java.util.List<HRegionInfo> createFsLayout(MasterProcedureEnv env, HTableDescriptor hTableDescriptor, java.util.List<HRegionInfo> newRegions, CreateTableProcedure.CreateHdfsRegions hdfsRegionHandler) throws java.io.IOException
java.io.IOException
protected static java.util.List<HRegionInfo> addTableToMeta(MasterProcedureEnv env, HTableDescriptor hTableDescriptor, java.util.List<HRegionInfo> regions) throws java.io.IOException
java.io.IOException
protected static void assignRegions(MasterProcedureEnv env, TableName tableName, java.util.List<HRegionInfo> regions) throws HBaseException, java.io.IOException
HBaseException
java.io.IOException
protected static void addRegionsToMeta(MasterProcedureEnv env, HTableDescriptor hTableDescriptor, java.util.List<HRegionInfo> regionInfos) throws java.io.IOException
java.io.IOException
protected static void updateTableDescCache(MasterProcedureEnv env, TableName tableName) throws java.io.IOException
java.io.IOException