Package org.apache.hadoop.hbase.master.procedure

Class TestProcedureWaitAndWake.MyPeerProcedure.MySubPeerProcedure

java.lang.Object
org.apache.hadoop.hbase.procedure2.Procedure<TEnvironment>
org.apache.hadoop.hbase.procedure2.StateMachineProcedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv,TState>
org.apache.hadoop.hbase.master.replication.AbstractPeerNoLockProcedure<Integer>
org.apache.hadoop.hbase.master.procedure.TestProcedureWaitAndWake.MyPeerProcedure.MySubPeerProcedure
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:
TestProcedureWaitAndWake.MyPeerProcedure
public static final class TestProcedureWaitAndWake.MyPeerProcedure.MySubPeerProcedure extends org.apache.hadoop.hbase.master.replication.AbstractPeerNoLockProcedure<Integer>

  • Nested Class Summary

    Nested classes/interfaces inherited from class org.apache.hadoop.hbase.procedure2.StateMachineProcedure

    org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow

    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.master.replication.AbstractPeerNoLockProcedure

    peerId

    Fields inherited from class org.apache.hadoop.hbase.procedure2.StateMachineProcedure

    stateCount

    Fields inherited from class org.apache.hadoop.hbase.procedure2.Procedure

    NO_PROC_ID, NO_TIMEOUT

  • Constructor Summary

    Constructors
    Constructor
    Description
    MySubPeerProcedure()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow
    executeFromState(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env, Integer state)
     
    protected Integer
    getInitialState()
     
    org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface.PeerOperationType
    getPeerOperationType()
     
    protected Integer
    getState(int stateId)
     
    protected int
    getStateId(Integer state)
     

    Methods inherited from class org.apache.hadoop.hbase.master.replication.AbstractPeerNoLockProcedure

    deserializeStateData, getPeerId, resetRetry, rollbackState, serializeStateData, setTimeoutFailure, suspend, waitInitialized

    Methods inherited from class org.apache.hadoop.hbase.procedure2.StateMachineProcedure

    abort, addChildProcedure, execute, failIfAborted, getCurrentState, getCurrentStateId, getCycles, isEofState, isRollbackSupported, isRollbackSupported, isYieldAfterExecutionStep, isYieldBeforeExecuteFromState, rollback, setNextState, toStringState

    Methods inherited from class org.apache.hadoop.hbase.procedure2.Procedure

    acquireLock, addStackIndex, afterExec, afterReplay, beforeExec, 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, isRunnable, isSuccess, isWaiting, releaseLock, removeStackIndex, setAbortFailure, setChildrenLatch, setExecuted, setFailure, setFailure, setLastUpdate, setNonceKey, setOwner, setOwner, setParentProcId, setProcId, setResult, setRootProcId, setStackIndexes, setState, setSubmittedTime, setTimeout, shouldWaitClientAck, skipPersistence, suspend, toString, toStringClass, toStringClassDetails, toStringDetails, toStringSimpleSB, updateMetricsOnFinish, updateMetricsOnSubmit, updateTimestamp, wasExecuted

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

  • Constructor Details

  • Method Details

    • getPeerOperationType

      public org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface.PeerOperationType getPeerOperationType()

    • executeFromState

      protected org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow executeFromState(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env, Integer state) throws org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException, org.apache.hadoop.hbase.procedure2.ProcedureYieldException, InterruptedException
      Specified by:
      executeFromState in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv,Integer>
      Throws:
      org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException
      org.apache.hadoop.hbase.procedure2.ProcedureYieldException
      InterruptedException

    • getState

      protected Integer getState(int stateId)
      Specified by:
      getState in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv,Integer>

    • getStateId

      protected int getStateId(Integer state)
      Specified by:
      getStateId in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv,Integer>

    • getInitialState

      protected Integer getInitialState()
      Specified by:
      getInitialState in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv,Integer>