@InterfaceAudience.Private @InterfaceStability.Evolving public abstract class SequentialProcedure<TEnvironment> extends Procedure<TEnvironment>
| Modifier and Type | Field and Description |
|---|---|
private boolean |
executed |
| Constructor and Description |
|---|
SequentialProcedure() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
deserializeStateData(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(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, getProcIdHashCode, getResult, getRootProcedureId, getStackIndexes, getStartTime, getState, getTimeout, getTimeRemaining, hasException, hasOwner, hasParent, hasTimeout, incChildrenLatch, isFailed, isFinished, isSuccess, isWaiting, isYieldAfterExecutionStep, newInstance, releaseLock, removeStackIndex, rollback, setAbortFailure, setChildrenLatch, setFailure, setFailure, setNonceKey, setOwner, setParentProcId, setProcId, setResult, setStackIndexes, setStartTime, setState, setTimeout, setTimeoutFailure, shouldWaitClientAck, toString, toStringClass, toStringClassDetails, toStringDetails, toStringSimpleSB, toStringState, updateTimestamp, validateClass, wasExecutedprotected Procedure[] doExecute(TEnvironment env) throws ProcedureYieldException, InterruptedException
ProceduredoExecute in class Procedure<TEnvironment>ProcedureYieldExceptionInterruptedExceptionprotected void doRollback(TEnvironment env) throws IOException, InterruptedException
ProceduredoRollback in class Procedure<TEnvironment>IOExceptionInterruptedExceptionprotected void serializeStateData(OutputStream stream) throws IOException
ProcedureserializeStateData in class Procedure<TEnvironment>stream - the stream that will contain the user serialized dataIOExceptionprotected void deserializeStateData(InputStream stream) throws IOException
ProceduredeserializeStateData in class Procedure<TEnvironment>stream - the stream that contains the user serialized dataIOExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.