public static class TestTransitPeerSyncReplicationStateProcedureBackoff.TestTransitPeerSyncReplicationStateProcedure extends org.apache.hadoop.hbase.master.replication.TransitPeerSyncReplicationStateProcedure
org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow
fromState
latch, SLEEP_INTERVAL_MS, UPDATE_LAST_SEQ_ID_BATCH_SIZE
Constructor and Description |
---|
TestTransitPeerSyncReplicationStateProcedure() |
TestTransitPeerSyncReplicationStateProcedure(String peerId,
org.apache.hadoop.hbase.replication.SyncReplicationState state) |
Modifier and Type | Method and Description |
---|---|
protected <T extends org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>> |
addChildProcedure(T... subProcedure) |
protected void |
createDirForRemoteWAL(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) |
protected void |
preTransit(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) |
protected void |
removeAllReplicationQueues(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) |
protected void |
reopenRegions(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) |
protected void |
setPeerNewSyncReplicationState(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) |
protected void |
transitPeerSyncReplicationState(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) |
private void |
tryFail() |
deserializeStateData, executeFromState, getInitialState, getPeerOperationType, getState, getStateId, serializeStateData
acquireLock, checkPeerModificationEnabled, enablePeer, getLatch, holdLock, refreshPeer, releaseLock, setLastPushedSequenceId, setLastPushedSequenceIdForTable
getPeerId, resetRetry, rollbackState, setTimeoutFailure, suspend, waitInitialized
abort, execute, failIfAborted, getCurrentState, getCurrentStateId, getCycles, isEofState, isRollbackSupported, isRollbackSupported, isYieldAfterExecutionStep, isYieldBeforeExecuteFromState, rollback, setNextState, toStringState
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, incChildrenLatch, isBypass, isFailed, isFinished, isInitializing, isLockedWhenLoading, isRunnable, isSuccess, isWaiting, 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
public TestTransitPeerSyncReplicationStateProcedure()
public TestTransitPeerSyncReplicationStateProcedure(String peerId, org.apache.hadoop.hbase.replication.SyncReplicationState state)
private void tryFail() throws org.apache.hadoop.hbase.replication.ReplicationException
org.apache.hadoop.hbase.replication.ReplicationException
protected <T extends org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>> void addChildProcedure(T... subProcedure)
addChildProcedure
in class org.apache.hadoop.hbase.procedure2.StateMachineProcedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv,org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerSyncReplicationStateTransitionState>
protected void preTransit(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) throws IOException
preTransit
in class org.apache.hadoop.hbase.master.replication.TransitPeerSyncReplicationStateProcedure
IOException
protected void setPeerNewSyncReplicationState(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) throws org.apache.hadoop.hbase.replication.ReplicationException
setPeerNewSyncReplicationState
in class org.apache.hadoop.hbase.master.replication.TransitPeerSyncReplicationStateProcedure
org.apache.hadoop.hbase.replication.ReplicationException
protected void removeAllReplicationQueues(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) throws org.apache.hadoop.hbase.replication.ReplicationException
removeAllReplicationQueues
in class org.apache.hadoop.hbase.master.replication.TransitPeerSyncReplicationStateProcedure
org.apache.hadoop.hbase.replication.ReplicationException
protected void reopenRegions(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
reopenRegions
in class org.apache.hadoop.hbase.master.replication.TransitPeerSyncReplicationStateProcedure
protected void transitPeerSyncReplicationState(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) throws org.apache.hadoop.hbase.replication.ReplicationException
transitPeerSyncReplicationState
in class org.apache.hadoop.hbase.master.replication.TransitPeerSyncReplicationStateProcedure
org.apache.hadoop.hbase.replication.ReplicationException
protected void createDirForRemoteWAL(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) throws IOException
createDirForRemoteWAL
in class org.apache.hadoop.hbase.master.replication.TransitPeerSyncReplicationStateProcedure
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.