org.apache.hadoop.hbase.master.replication

类 RefreshPeerProcedure

java.lang.Object

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

org.apache.hadoop.hbase.master.procedure.ServerRemoteProcedure

org.apache.hadoop.hbase.master.replication.RefreshPeerProcedure

所有已实现的接口:

Comparable<Procedure<MasterProcedureEnv>>, PeerProcedureInterface, RemoteProcedureDispatcher.RemoteProcedure<MasterProcedureEnv,ServerName>

@InterfaceAudience.Private
public class RefreshPeerProcedure
extends ServerRemoteProcedure
implements PeerProcedureInterface, RemoteProcedureDispatcher.RemoteProcedure<MasterProcedureEnv,ServerName>

嵌套类概要

从类继承的嵌套类/接口 org.apache.hadoop.hbase.procedure2.Procedure

Procedure.LockState

从接口继承的嵌套类/接口 org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface

PeerProcedureInterface.PeerOperationType

字段概要

从类继承的字段 org.apache.hadoop.hbase.master.procedure.ServerRemoteProcedure

dispatched, event, succ, targetServer

从类继承的字段 org.apache.hadoop.hbase.procedure2.Procedure

NO_PROC_ID, NO_TIMEOUT

构造器概要

构造器

构造器和说明
RefreshPeerProcedure()
RefreshPeerProcedure(String peerId, PeerProcedureInterface.PeerOperationType type, ServerName targetServer)

方法概要

限定符和类型	方法和说明
protected boolean	abort(MasterProcedureEnv env)
protected void	complete(MasterProcedureEnv env, Throwable error)
protected void	deserializeStateData(ProcedureStateSerializer serializer)
String	getPeerId()
PeerProcedureInterface.PeerOperationType	getPeerOperationType()
RemoteProcedureDispatcher.RemoteOperation	remoteCallBuild(MasterProcedureEnv env, ServerName remote)
protected void	rollback(MasterProcedureEnv env)
protected void	serializeStateData(ProcedureStateSerializer serializer)
protected boolean	waitInitialized(MasterProcedureEnv env)

从类继承的方法 org.apache.hadoop.hbase.master.procedure.ServerRemoteProcedure

completionCleanup, execute, remoteCallFailed, remoteOperationCompleted, remoteOperationFailed

从类继承的方法 org.apache.hadoop.hbase.procedure2.Procedure

acquireLock, addStackIndex, afterReplay, beforeReplay, bypass, compareTo, 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, isYieldAfterExecutionStep, releaseLock, removeStackIndex, setAbortFailure, setChildrenLatch, setFailure, setFailure, setLastUpdate, setNonceKey, setOwner, setOwner, setParentProcId, setProcId, setResult, setRootProcId, setStackIndexes, setState, setSubmittedTime, setTimeout, setTimeoutFailure, shouldWaitClientAck, skipPersistence, toString, toStringClass, toStringClassDetails, toStringDetails, toStringSimpleSB, toStringState, updateMetricsOnFinish, updateMetricsOnSubmit, updateTimestamp, wasExecuted

从类继承的方法 java.lang.Object

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

从接口继承的方法 org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure

remoteCallFailed, remoteOperationCompleted, remoteOperationFailed, storeInDispatchedQueue

构造器详细资料

RefreshPeerProcedure

public RefreshPeerProcedure()

RefreshPeerProcedure

public RefreshPeerProcedure(String peerId,
                            PeerProcedureInterface.PeerOperationType type,
                            ServerName targetServer)

方法详细资料

getPeerId

public String getPeerId()

指定者:

getPeerId 在接口中 PeerProcedureInterface

getPeerOperationType

public PeerProcedureInterface.PeerOperationType getPeerOperationType()

指定者:

getPeerOperationType 在接口中 PeerProcedureInterface

remoteCallBuild

public RemoteProcedureDispatcher.RemoteOperation remoteCallBuild(MasterProcedureEnv env,
                                                                 ServerName remote)

指定者:

remoteCallBuild 在接口中 RemoteProcedureDispatcher.RemoteProcedure<MasterProcedureEnv,ServerName>

complete

protected void complete(MasterProcedureEnv env,
                        Throwable error)

指定者:

complete 在类中 ServerRemoteProcedure

rollback

protected void rollback(MasterProcedureEnv env)
                 throws IOException,
                        InterruptedException

指定者:

rollback 在类中 Procedure<MasterProcedureEnv>

抛出:

IOException

InterruptedException

abort

protected boolean abort(MasterProcedureEnv env)

指定者:

abort 在类中 Procedure<MasterProcedureEnv>

waitInitialized

protected boolean waitInitialized(MasterProcedureEnv env)

覆盖:

waitInitialized 在类中 Procedure<MasterProcedureEnv>

serializeStateData

protected void serializeStateData(ProcedureStateSerializer serializer)
                           throws IOException

指定者:

serializeStateData 在类中 Procedure<MasterProcedureEnv>

抛出:

IOException

deserializeStateData

protected void deserializeStateData(ProcedureStateSerializer serializer)
                             throws IOException

指定者:

deserializeStateData 在类中 Procedure<MasterProcedureEnv>

抛出:

IOException