Package org.apache.hadoop.hbase.master.replication

Class RemovePeerProcedure

java.lang.Object

org.apache.hadoop.hbase.procedure2.Procedure<TEnvironment>

org.apache.hadoop.hbase.procedure2.StateMachineProcedure<MasterProcedureEnv,TState>

org.apache.hadoop.hbase.master.replication.AbstractPeerNoLockProcedure<TState>

org.apache.hadoop.hbase.master.replication.AbstractPeerProcedure<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState>

org.apache.hadoop.hbase.master.replication.ModifyPeerProcedure

org.apache.hadoop.hbase.master.replication.RemovePeerProcedure

All Implemented Interfaces:

Comparable<Procedure<MasterProcedureEnv>>, PeerProcedureInterface

@Private
public class RemovePeerProcedure
extends ModifyPeerProcedure

The procedure for removing a replication peer.

Nested Class Summary

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

StateMachineProcedure.Flow

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

Procedure.LockState

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface

PeerProcedureInterface.PeerOperationType

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private List<Long>	ongoingAssignReplicationQueuesProcIds
private ReplicationPeerConfig	peerConfig

Fields inherited from class org.apache.hadoop.hbase.master.replication.AbstractPeerProcedure

latch, SLEEP_INTERVAL_MS, UPDATE_LAST_SEQ_ID_BATCH_SIZE

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
RemovePeerProcedure()
RemovePeerProcedure(String peerId)

Method Summary

Modifier and Type	Method	Description
private void	checkAssignReplicationQueuesFinished(MasterProcedureEnv env)
protected void	deserializeStateData(ProcedureStateSerializer serializer)	Called on store load to allow the user to decode the previously serialized state.
PeerProcedureInterface.PeerOperationType	getPeerOperationType()
protected void	postPeerModification(MasterProcedureEnv env)	Called before we finish the procedure.
protected void	prePeerModification(MasterProcedureEnv env)	Called before we start the actual processing.
private void	removeRemoteWALs(MasterProcedureEnv env)
protected void	serializeStateData(ProcedureStateSerializer serializer)	The user-level code of the procedure may have some state to persist (e.g.
protected void	updatePeerStorage(MasterProcedureEnv env)

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

enablePeerBeforeFinish, executeFromState, getInitialState, getNewPeerConfig, getOldPeerConfig, getState, getStateId, nextStateAfterRefresh, releaseLatch, reopenRegions, updateLastPushedSequenceIdForSerialPeer

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

acquireLock, checkPeerModificationEnabled, enablePeer, getLatch, holdLock, refreshPeer, releaseLock, setLastPushedSequenceId, setLastPushedSequenceIdForTable

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

getPeerId, resetRetry, rollbackState, 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

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface

getPeerId

Field Details

LOG

private static final org.slf4j.Logger LOG

peerConfig

private ReplicationPeerConfig peerConfig

ongoingAssignReplicationQueuesProcIds

private List<Long> ongoingAssignReplicationQueuesProcIds

Constructor Details

RemovePeerProcedure

public RemovePeerProcedure()

RemovePeerProcedure

public RemovePeerProcedure(String peerId)

Method Details

getPeerOperationType

public PeerProcedureInterface.PeerOperationType getPeerOperationType()

prePeerModification

protected void prePeerModification(MasterProcedureEnv env)
                            throws IOException

Description copied from class: ModifyPeerProcedure

Called before we start the actual processing. The implementation should call the pre CP hook, and also the pre-check for the peer modification.

If an IOException is thrown then we will give up and mark the procedure as failed directly. If all checks passes then the procedure can not be rolled back any more.

Specified by:

prePeerModification in class ModifyPeerProcedure

Throws:

IOException

updatePeerStorage

protected void updatePeerStorage(MasterProcedureEnv env)
                          throws ReplicationException

Specified by:

updatePeerStorage in class ModifyPeerProcedure

Throws:

ReplicationException

removeRemoteWALs

private void removeRemoteWALs(MasterProcedureEnv env)
                       throws IOException

Throws:

IOException

checkAssignReplicationQueuesFinished

private void checkAssignReplicationQueuesFinished(MasterProcedureEnv env)
                                           throws ProcedureSuspendedException

Throws:

ProcedureSuspendedException

postPeerModification

protected void postPeerModification(MasterProcedureEnv env)
                             throws IOException,
ReplicationException,
ProcedureSuspendedException

Description copied from class: ModifyPeerProcedure

Called before we finish the procedure. The implementation can do some logging work, and also call the coprocessor hook if any.

Notice that, since we have already done the actual work, throwing IOException here will not fail this procedure, we will just ignore it and finish the procedure as suceeded. If ReplicationException is thrown we will retry since this usually means we fails to update the peer storage.

Specified by:

postPeerModification in class ModifyPeerProcedure

Throws:

IOException

ReplicationException

ProcedureSuspendedException

serializeStateData

protected void serializeStateData(ProcedureStateSerializer serializer)
                           throws IOException

Description copied from class: Procedure

The user-level code of the procedure may have some state to persist (e.g. input arguments or current position in the processing state) to be able to resume on failure.

Overrides:

serializeStateData in class AbstractPeerNoLockProcedure<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState>

Parameters:

serializer - stores the serializable state

Throws:

IOException

deserializeStateData

protected void deserializeStateData(ProcedureStateSerializer serializer)
                             throws IOException

Description copied from class: Procedure

Called on store load to allow the user to decode the previously serialized state.

Overrides:

deserializeStateData in class AbstractPeerNoLockProcedure<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState>

Parameters:

serializer - contains the serialized state

Throws:

IOException