public static class TestMasterProcedureQueue.TestTableProcedure extends Procedure<Void> implements TableProcedureInterface
TableProcedureInterface.TableOperationType
Constructor and Description |
---|
TestTableProcedure() |
TestTableProcedure(long procId,
TableName tableName,
TableProcedureInterface.TableOperationType opType) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
abort(Void env)
The abort() call is asynchronous and each procedure must decide how to deal
with that, if they want to be abortable.
|
protected void |
deserializeStateData(InputStream stream)
Called on store load to allow the user to decode the previously serialized
state.
|
protected Procedure[] |
execute(Void env)
The main code of the procedure.
|
TableName |
getTableName() |
TableProcedureInterface.TableOperationType |
getTableOperationType()
Given an operation type we can take decisions about what to do with pending operations.
|
protected void |
rollback(Void env)
The code to undo what done by the execute() code.
|
protected void |
serializeStateData(OutputStream stream)
The user-level code of the procedure may have some state to
persist (e.g.
|
acquireLock, addStackIndex, beforeReplay, childrenCountDown, compareTo, completionCleanup, convert, convert, createProcedureInfo, doExecute, doRollback, elapsedTime, getException, getLastUpdate, getOwner, getParentProcId, getProcId, getResult, getRootProcedureId, getStackIndexes, getStartTime, getState, getTimeout, getTimeRemaining, hasException, hasOwner, hasParent, hasTimeout, incChildrenLatch, isFailed, isFinished, isSuccess, isWaiting, newInstance, releaseLock, removeStackIndex, setAbortFailure, setChildrenLatch, setFailure, setFailure, setOwner, setParentProcId, setProcId, setResult, setStackIndexes, setStartTime, setState, setTimeout, setTimeoutFailure, toString, toStringClass, toStringClassDetails, updateTimestamp, validateClass, wasExecuted
public TestTableProcedure()
public TestTableProcedure(long procId, TableName tableName, TableProcedureInterface.TableOperationType opType)
public TableName getTableName()
getTableName
in interface TableProcedureInterface
public TableProcedureInterface.TableOperationType getTableOperationType()
TableProcedureInterface
getTableOperationType
in interface TableProcedureInterface
protected Procedure[] execute(Void env)
Procedure
protected void rollback(Void env)
Procedure
protected boolean abort(Void env)
Procedure
protected void serializeStateData(OutputStream stream) throws IOException
Procedure
serializeStateData
in class Procedure<Void>
stream
- the stream that will contain the user serialized dataIOException
protected void deserializeStateData(InputStream stream) throws IOException
Procedure
deserializeStateData
in class Procedure<Void>
stream
- the stream that contains the user serialized dataIOException