public class RecoverMetaProcedure extends <any> implements MetaProcedureInterface
MetaProcedureInterface.MetaOperationType
Constructor and Description |
---|
RecoverMetaProcedure()
This constructor is also used when deserializing from a procedure store; we'll construct one
of these then call #deserializeStateData(InputStream).
|
RecoverMetaProcedure(ServerName failedMetaServer,
boolean shouldSplitLog)
Call this constructor to queue up a
RecoverMetaProcedure in response to meta
carrying server crash |
RecoverMetaProcedure(ServerName failedMetaServer,
boolean shouldSplitLog,
ProcedurePrepareLatch latch)
Constructor with latch, for blocking/ sync usage
|
Modifier and Type | Method and Description |
---|---|
protected LockState |
acquireLock(MasterProcedureEnv env) |
protected void |
completionCleanup(MasterProcedureEnv env) |
protected void |
deserializeStateData(ProcedureStateSerializer serializer) |
protected Flow |
executeFromState(MasterProcedureEnv env,
MasterProcedureProtos.RecoverMetaState state) |
protected MasterProcedureProtos.RecoverMetaState |
getInitialState() |
protected MasterProcedureProtos.RecoverMetaState |
getState(int stateId) |
protected int |
getStateId(MasterProcedureProtos.RecoverMetaState recoverMetaState) |
protected void |
releaseLock(MasterProcedureEnv env) |
protected void |
rollbackState(MasterProcedureEnv env,
MasterProcedureProtos.RecoverMetaState recoverMetaState) |
protected void |
serializeStateData(ProcedureStateSerializer serializer) |
protected void |
toStringClassDetails(java.lang.StringBuilder sb) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getMetaOperationType
public RecoverMetaProcedure(ServerName failedMetaServer, boolean shouldSplitLog)
RecoverMetaProcedure
in response to meta
carrying server crashfailedMetaServer
- failed/ crashed region server that was carrying metashouldSplitLog
- split log file of meta regionpublic RecoverMetaProcedure(ServerName failedMetaServer, boolean shouldSplitLog, ProcedurePrepareLatch latch)
public RecoverMetaProcedure()
protected Flow executeFromState(MasterProcedureEnv env, MasterProcedureProtos.RecoverMetaState state) throws ProcedureSuspendedException, ProcedureYieldException, java.lang.InterruptedException
ProcedureSuspendedException
ProcedureYieldException
java.lang.InterruptedException
protected void rollbackState(MasterProcedureEnv env, MasterProcedureProtos.RecoverMetaState recoverMetaState) throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
protected MasterProcedureProtos.RecoverMetaState getState(int stateId)
protected int getStateId(MasterProcedureProtos.RecoverMetaState recoverMetaState)
protected MasterProcedureProtos.RecoverMetaState getInitialState()
protected void toStringClassDetails(java.lang.StringBuilder sb)
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)
protected void releaseLock(MasterProcedureEnv env)
protected void completionCleanup(MasterProcedureEnv env)