public static class TestYieldProcedures.TestStateMachineProcedure extends org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestYieldProcedures.TestProcEnv,TestYieldProcedures.TestStateMachineProcedure.State>
Modifier and Type | Class and Description |
---|---|
static class |
TestYieldProcedures.TestStateMachineProcedure.ExecutionInfo |
(package private) static class |
TestYieldProcedures.TestStateMachineProcedure.State |
Modifier and Type | Field and Description |
---|---|
private AtomicBoolean |
aborted |
private boolean |
abortOnFinalStep |
private ArrayList<TestYieldProcedures.TestStateMachineProcedure.ExecutionInfo> |
executionInfo |
private boolean |
throwInterruptOnceOnEachStep |
Constructor and Description |
---|
TestStateMachineProcedure() |
TestStateMachineProcedure(boolean abortOnFinalStep,
boolean throwInterruptOnceOnEachStep) |
addChildProcedure, deserializeStateData, execute, failIfAborted, getCurrentState, getCurrentStateId, getCycles, isEofState, isRollbackSupported, isYieldAfterExecutionStep, rollback, serializeStateData, setNextState, toStringState
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
private final ArrayList<TestYieldProcedures.TestStateMachineProcedure.ExecutionInfo> executionInfo
private final AtomicBoolean aborted
private final boolean throwInterruptOnceOnEachStep
private final boolean abortOnFinalStep
public TestStateMachineProcedure()
public TestStateMachineProcedure(boolean abortOnFinalStep, boolean throwInterruptOnceOnEachStep)
public ArrayList<TestYieldProcedures.TestStateMachineProcedure.ExecutionInfo> getExecutionInfo()
protected boolean isRollbackSupported(TestYieldProcedures.TestStateMachineProcedure.State state)
isRollbackSupported
in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestYieldProcedures.TestProcEnv,TestYieldProcedures.TestStateMachineProcedure.State>
protected org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow executeFromState(TestYieldProcedures.TestProcEnv env, TestYieldProcedures.TestStateMachineProcedure.State state) throws InterruptedException
executeFromState
in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestYieldProcedures.TestProcEnv,TestYieldProcedures.TestStateMachineProcedure.State>
InterruptedException
protected void rollbackState(TestYieldProcedures.TestProcEnv env, TestYieldProcedures.TestStateMachineProcedure.State state) throws InterruptedException
rollbackState
in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestYieldProcedures.TestProcEnv,TestYieldProcedures.TestStateMachineProcedure.State>
InterruptedException
protected TestYieldProcedures.TestStateMachineProcedure.State getState(int stateId)
getState
in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestYieldProcedures.TestProcEnv,TestYieldProcedures.TestStateMachineProcedure.State>
protected int getStateId(TestYieldProcedures.TestStateMachineProcedure.State state)
getStateId
in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestYieldProcedures.TestProcEnv,TestYieldProcedures.TestStateMachineProcedure.State>
protected TestYieldProcedures.TestStateMachineProcedure.State getInitialState()
getInitialState
in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestYieldProcedures.TestProcEnv,TestYieldProcedures.TestStateMachineProcedure.State>
protected boolean isYieldBeforeExecuteFromState(TestYieldProcedures.TestProcEnv env, TestYieldProcedures.TestStateMachineProcedure.State state)
isYieldBeforeExecuteFromState
in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestYieldProcedures.TestProcEnv,TestYieldProcedures.TestStateMachineProcedure.State>
protected boolean abort(TestYieldProcedures.TestProcEnv env)
abort
in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<TestYieldProcedures.TestProcEnv,TestYieldProcedures.TestStateMachineProcedure.State>
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.