@InterfaceAudience.Private @InterfaceStability.Evolving public abstract class SequentialProcedure<TEnvironment> extends Procedure<TEnvironment>
Constructor and Description |
---|
SequentialProcedure() |
Modifier and Type | Method and Description |
---|---|
protected void |
deserializeStateData(java.io.InputStream stream)
Called on store load to allow the user to decode the previously serialized
state.
|
protected Procedure[] |
doExecute(TEnvironment env)
Internal method called by the ProcedureExecutor that starts the
user-level code execute().
|
protected void |
doRollback(TEnvironment env)
Internal method called by the ProcedureExecutor that starts the
user-level code rollback().
|
protected void |
serializeStateData(java.io.OutputStream stream)
The user-level code of the procedure may have some state to
persist (e.g.
|
abort, acquireLock, addStackIndex, beforeReplay, childrenCountDown, compareTo, completionCleanup, convert, convert, createProcedureInfo, elapsedTime, execute, getException, getLastUpdate, getNonceKey, getOwner, getParentProcId, getProcId, getResult, getRootProcedureId, getStackIndexes, getStartTime, getState, getTimeout, getTimeRemaining, hasException, hasOwner, hasParent, hasTimeout, incChildrenLatch, isFailed, isFinished, isSuccess, isWaiting, newInstance, releaseLock, removeStackIndex, rollback, setAbortFailure, setChildrenLatch, setFailure, setFailure, setNonceKey, setOwner, setParentProcId, setProcId, setResult, setStackIndexes, setStartTime, setState, setTimeout, setTimeoutFailure, toString, toStringClass, toStringClassDetails, toStringDetails, toStringSimpleSB, updateTimestamp, validateClass, wasExecuted
protected Procedure[] doExecute(TEnvironment env) throws ProcedureYieldException, java.lang.InterruptedException
Procedure
doExecute
in class Procedure<TEnvironment>
env
- the environment passed to the ProcedureExecutorProcedureYieldException
- the procedure will be added back to the queue and retried laterjava.lang.InterruptedException
protected void doRollback(TEnvironment env) throws java.io.IOException
Procedure
doRollback
in class Procedure<TEnvironment>
env
- the environment passed to the ProcedureExecutorjava.io.IOException
protected void serializeStateData(java.io.OutputStream stream) throws java.io.IOException
Procedure
serializeStateData
in class Procedure<TEnvironment>
stream
- the stream that will contain the user serialized datajava.io.IOException
- failure to stream dataprotected void deserializeStateData(java.io.InputStream stream) throws java.io.IOException
Procedure
deserializeStateData
in class Procedure<TEnvironment>
stream
- the stream that contains the user serialized datajava.io.IOException