Class TestProcedureRecovery.TestStateMachineProcedure
java.lang.Object
org.apache.hadoop.hbase.procedure2.Procedure<TEnvironment>
org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,TestProcedureRecovery.TestStateMachineProcedure.State>
org.apache.hadoop.hbase.procedure2.TestProcedureRecovery.TestStateMachineProcedure
- All Implemented Interfaces:
Comparable<org.apache.hadoop.hbase.procedure2.Procedure<TestProcedureRecovery.TestProcEnv>>
- Enclosing class:
- TestProcedureRecovery
public static class TestProcedureRecovery.TestStateMachineProcedure
extends org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,TestProcedureRecovery.TestStateMachineProcedure.State>
-
Nested Class Summary
Modifier and TypeClassDescription(package private) static enum
Nested classes/interfaces inherited from class org.apache.hadoop.hbase.procedure2.StateMachineProcedure
org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow
Nested classes/interfaces inherited from class org.apache.hadoop.hbase.procedure2.Procedure
org.apache.hadoop.hbase.procedure2.Procedure.LockState
-
Field Summary
Fields inherited from class org.apache.hadoop.hbase.procedure2.StateMachineProcedure
stateCount
Fields inherited from class org.apache.hadoop.hbase.procedure2.Procedure
NO_PROC_ID, NO_TIMEOUT
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected boolean
protected void
deserializeStateData
(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer) protected org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow
executeFromState
(TestProcedureRecovery.TestProcEnv env, TestProcedureRecovery.TestStateMachineProcedure.State state) getState
(int stateId) protected int
protected boolean
protected void
rollbackState
(TestProcedureRecovery.TestProcEnv env, TestProcedureRecovery.TestStateMachineProcedure.State state) protected void
serializeStateData
(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer) Methods inherited from class org.apache.hadoop.hbase.procedure2.StateMachineProcedure
addChildProcedure, execute, failIfAborted, getCurrentState, getCurrentStateId, getCycles, isEofState, isRollbackSupported, isYieldAfterExecutionStep, isYieldBeforeExecuteFromState, rollback, setNextState, toStringState
Methods inherited from class org.apache.hadoop.hbase.procedure2.Procedure
acquireLock, addStackIndex, afterReplay, beforeReplay, bypass, compareTo, completionCleanup, doAcquireLock, doExecute, doReleaseLock, doRollback, elapsedTime, getChildrenLatch, getException, getLastUpdate, getNonceKey, getOwner, getParentProcId, getProcedureMetrics, getProcId, getProcIdHashCode, getProcName, getResult, getRootProcedureId, getRootProcId, getStackIndexes, getState, getSubmittedTime, getTimeout, getTimeoutTimestamp, hasChildren, hasException, hasLock, hasOwner, hasParent, hasTimeout, haveSameParent, holdLock, incChildrenLatch, isBypass, isFailed, isFinished, isInitializing, isLockedWhenLoading, isRunnable, isSuccess, isWaiting, lockedWhenLoading, needPersistence, releaseLock, removeStackIndex, resetPersistence, restoreLock, setAbortFailure, setChildrenLatch, setExecuted, setFailure, setFailure, setLastUpdate, setNonceKey, setOwner, setOwner, setParentProcId, setProcId, setResult, setRootProcId, setStackIndexes, setState, setSubmittedTime, setTimeout, setTimeoutFailure, shouldWaitClientAck, skipPersistence, suspend, toString, toStringClass, toStringClassDetails, toStringDetails, toStringSimpleSB, tryRunnable, updateMetricsOnFinish, updateMetricsOnSubmit, updateTimestamp, waitInitialized, wasExecuted
-
Field Details
-
aborted
-
iResult
-
submitChildProc
-
-
Constructor Details
-
TestStateMachineProcedure
public TestStateMachineProcedure() -
TestStateMachineProcedure
-
-
Method Details
-
executeFromState
protected org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow executeFromState(TestProcedureRecovery.TestProcEnv env, TestProcedureRecovery.TestStateMachineProcedure.State state) - Specified by:
executeFromState
in classorg.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,
TestProcedureRecovery.TestStateMachineProcedure.State>
-
isRollbackSupported
- Overrides:
isRollbackSupported
in classorg.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,
TestProcedureRecovery.TestStateMachineProcedure.State>
-
rollbackState
protected void rollbackState(TestProcedureRecovery.TestProcEnv env, TestProcedureRecovery.TestStateMachineProcedure.State state) - Specified by:
rollbackState
in classorg.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,
TestProcedureRecovery.TestStateMachineProcedure.State>
-
getState
- Specified by:
getState
in classorg.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,
TestProcedureRecovery.TestStateMachineProcedure.State>
-
getStateId
- Specified by:
getStateId
in classorg.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,
TestProcedureRecovery.TestStateMachineProcedure.State>
-
getInitialState
- Specified by:
getInitialState
in classorg.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,
TestProcedureRecovery.TestStateMachineProcedure.State>
-
abort
- Overrides:
abort
in classorg.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,
TestProcedureRecovery.TestStateMachineProcedure.State>
-
serializeStateData
protected void serializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer) throws IOException - Overrides:
serializeStateData
in classorg.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,
TestProcedureRecovery.TestStateMachineProcedure.State> - Throws:
IOException
-
deserializeStateData
protected void deserializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer) throws IOException - Overrides:
deserializeStateData
in classorg.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestProcedureRecovery.TestProcEnv,
TestProcedureRecovery.TestStateMachineProcedure.State> - Throws:
IOException
-