org.apache.hadoop.hbase.procedure2

Interface RemoteProcedureDispatcher.RemoteProcedure<TEnv,TRemote>

All Known Implementing Classes:

AssignProcedure, CloseRegionProcedure, OpenRegionProcedure, RefreshPeerProcedure, RegionRemoteProcedureBase, RegionTransitionProcedure, ServerRemoteProcedure, SplitWALRemoteProcedure, SwitchRpcThrottleRemoteProcedure, UnassignProcedure

Enclosing class:

RemoteProcedureDispatcher<TEnv,TRemote extends Comparable<TRemote>>

public static interface RemoteProcedureDispatcher.RemoteProcedure<TEnv,TRemote>

Remote procedure reference.

Method Summary

Modifier and Type	Method and Description
Optional<RemoteProcedureDispatcher.RemoteOperation>	remoteCallBuild(TEnv env, TRemote remote) For building the remote operation.
void	remoteCallFailed(TEnv env, TRemote remote, IOException exception) Called when the executeProcedure call is failed.
void	remoteOperationCompleted(TEnv env) Called when RS tells the remote procedure is succeeded through the reportProcedureDone method.
void	remoteOperationFailed(TEnv env, RemoteProcedureException error) Called when RS tells the remote procedure is failed through the reportProcedureDone method.
default boolean	storeInDispatchedQueue() Whether store this remote procedure in dispatched queue only OpenRegionProcedure and CloseRegionProcedure return false since they are not fully controlled by dispatcher

Method Detail

remoteCallBuild

Optional<RemoteProcedureDispatcher.RemoteOperation> remoteCallBuild(TEnv env,
                                                                    TRemote remote)

For building the remote operation. May be empty if no need to send remote call. Usually, this means the RemoteProcedure has been finished already. This is possible, as we may have already sent the procedure to RS but then the rpc connection is broken so the executeProcedures call fails, but the RS does receive the procedure and execute it and then report back, before we retry again.

remoteCallFailed

void remoteCallFailed(TEnv env,
                      TRemote remote,
                      IOException exception)

Called when the executeProcedure call is failed.

remoteOperationCompleted

void remoteOperationCompleted(TEnv env)

Called when RS tells the remote procedure is succeeded through the reportProcedureDone method.

remoteOperationFailed

void remoteOperationFailed(TEnv env,
                           RemoteProcedureException error)

Called when RS tells the remote procedure is failed through the reportProcedureDone method.

storeInDispatchedQueue

default boolean storeInDispatchedQueue()

Whether store this remote procedure in dispatched queue only OpenRegionProcedure and CloseRegionProcedure return false since they are not fully controlled by dispatcher