Class TestTableProcedureWaitingQueueCleanup.NonTableProcedure
java.lang.Object
org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>
org.apache.hadoop.hbase.master.procedure.TestTableProcedureWaitingQueueCleanup.NonTableProcedure
- All Implemented Interfaces:
Comparable<org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>>
,org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface
- Enclosing class:
- TestTableProcedureWaitingQueueCleanup
public static class TestTableProcedureWaitingQueueCleanup.NonTableProcedure
extends org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>
implements org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.hadoop.hbase.procedure2.Procedure
org.apache.hadoop.hbase.procedure2.Procedure.LockState
Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface
org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface.PeerOperationType
-
Field Summary
Fields inherited from class org.apache.hadoop.hbase.procedure2.Procedure
NO_PROC_ID, NO_TIMEOUT
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected boolean
abort
(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) protected void
deserializeStateData
(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer) protected org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>[]
execute
(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface.PeerOperationType
protected void
rollback
(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) protected void
serializeStateData
(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer) Methods inherited from class org.apache.hadoop.hbase.procedure2.Procedure
acquireLock, addStackIndex, afterReplay, beforeReplay, bypass, compareTo, completionCleanup, doExecute, 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, isRollbackSupported, isRunnable, isSuccess, isWaiting, isYieldAfterExecutionStep, releaseLock, removeStackIndex, 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, toStringState, updateMetricsOnFinish, updateMetricsOnSubmit, updateTimestamp, waitInitialized, wasExecuted
-
Field Details
-
created
-
-
Constructor Details
-
NonTableProcedure
public NonTableProcedure()
-
-
Method Details
-
execute
protected org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>[] execute(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) throws org.apache.hadoop.hbase.procedure2.ProcedureYieldException, org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException, InterruptedException - Specified by:
execute
in classorg.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>
- Throws:
org.apache.hadoop.hbase.procedure2.ProcedureYieldException
org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException
InterruptedException
-
rollback
protected void rollback(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) throws IOException, InterruptedException - Specified by:
rollback
in classorg.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>
- Throws:
IOException
InterruptedException
-
abort
- Specified by:
abort
in classorg.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>
-
serializeStateData
protected void serializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer) throws IOException - Specified by:
serializeStateData
in classorg.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>
- Throws:
IOException
-
deserializeStateData
protected void deserializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer) throws IOException - Specified by:
deserializeStateData
in classorg.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>
- Throws:
IOException
-
getPeerId
- Specified by:
getPeerId
in interfaceorg.apache.hadoop.hbase.master.procedure.PeerProcedureInterface
-
getPeerOperationType
public org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface.PeerOperationType getPeerOperationType()- Specified by:
getPeerOperationType
in interfaceorg.apache.hadoop.hbase.master.procedure.PeerProcedureInterface
-