org.apache.hadoop.hbase.master.procedure

Class RSProcedureDispatcher.ExecuteProceduresRemoteCall

java.lang.Object

org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher.AbstractRSRemoteCall

org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher.ExecuteProceduresRemoteCall

All Implemented Interfaces:

Runnable, RSProcedureDispatcher.RemoteProcedureResolver

Direct Known Subclasses:

RSProcedureDispatcher.DeadRSRemoteCall

Enclosing class:

RSProcedureDispatcher

protected class RSProcedureDispatcher.ExecuteProceduresRemoteCall
extends RSProcedureDispatcher.AbstractRSRemoteCall
implements RSProcedureDispatcher.RemoteProcedureResolver

Field Summary

Fields

Modifier and Type	Field and Description
protected Set<RemoteProcedureDispatcher.RemoteProcedure>	remoteProcedures
protected org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest.Builder	request

Constructor Summary

Constructors

Constructor and Description
ExecuteProceduresRemoteCall(ServerName serverName, Set<RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures)

Method Summary

Modifier and Type	Method and Description
void	dispatchCloseRequests(MasterProcedureEnv env, List<RSProcedureDispatcher.RegionCloseOperation> operations)
void	dispatchOpenRequests(MasterProcedureEnv env, List<RSProcedureDispatcher.RegionOpenOperation> operations)
private void	remoteCallCompleted(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse response)
protected void	remoteCallFailed(MasterProcedureEnv env, IOException e)
void	run()
protected org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse	sendRequest(ServerName serverName, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest request)

Methods inherited from class org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher.AbstractRSRemoteCall

getRsAdmin, getServerName, scheduleForRetry, unwrapException

Methods inherited from class java.lang.Object

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

Field Detail

remoteProcedures

protected final Set<RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures

request

protected org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest.Builder request

Constructor Detail

ExecuteProceduresRemoteCall

public ExecuteProceduresRemoteCall(ServerName serverName,
                                   Set<RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

dispatchOpenRequests

public void dispatchOpenRequests(MasterProcedureEnv env,
                                 List<RSProcedureDispatcher.RegionOpenOperation> operations)

Specified by:

dispatchOpenRequests in interface RSProcedureDispatcher.RemoteProcedureResolver

dispatchCloseRequests

public void dispatchCloseRequests(MasterProcedureEnv env,
                                  List<RSProcedureDispatcher.RegionCloseOperation> operations)

Specified by:

dispatchCloseRequests in interface RSProcedureDispatcher.RemoteProcedureResolver

sendRequest

protected org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse sendRequest(ServerName serverName,
                                                                                                              org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest request)
                                                                                                       throws IOException

Throws:

IOException

remoteCallCompleted

private void remoteCallCompleted(MasterProcedureEnv env,
                                 org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse response)

remoteCallFailed

protected void remoteCallFailed(MasterProcedureEnv env,
                                IOException e)