protected class RSProcedureDispatcher.ExecuteProceduresRemoteCall extends Object implements RSProcedureDispatcher.RemoteProcedureResolver, Runnable
Modifier and Type | Field and Description |
---|---|
private static int |
DEFAULT_RS_RPC_RETRY_INTERVAL |
private long |
maxWaitTime |
private int |
numberOfAttemptsSoFar |
private Set<RemoteProcedureDispatcher.RemoteProcedure> |
remoteProcedures |
private org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest.Builder |
request |
private static String |
RS_RPC_RETRY_INTERVAL_CONF_KEY |
private long |
rsRpcRetryInterval |
private ServerName |
serverName |
Constructor and Description |
---|
ExecuteProceduresRemoteCall(ServerName serverName,
Set<RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures) |
Modifier and Type | Method and Description |
---|---|
void |
dispatchCloseRequests(MasterProcedureEnv env,
List<RSProcedureDispatcher.RegionCloseOperation> operations) |
void |
dispatchOpenRequests(MasterProcedureEnv env,
List<RSProcedureDispatcher.RegionOpenOperation> operations) |
void |
dispatchServerOperations(MasterProcedureEnv env,
List<RSProcedureDispatcher.ServerOperation> operations) |
private long |
getMaxWaitTime() |
private org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface |
getRsAdmin() |
protected ServerName |
getServerName() |
protected void |
remoteCallFailed(MasterProcedureEnv env,
IOException e) |
void |
run() |
private boolean |
scheduleForRetry(IOException e) |
protected org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse |
sendRequest(ServerName serverName,
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest request) |
private IOException |
unwrapException(IOException e) |
private final ServerName serverName
private final Set<RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures
private int numberOfAttemptsSoFar
private long maxWaitTime
private final long rsRpcRetryInterval
private static final String RS_RPC_RETRY_INTERVAL_CONF_KEY
private static final int DEFAULT_RS_RPC_RETRY_INTERVAL
private org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest.Builder request
public ExecuteProceduresRemoteCall(ServerName serverName, Set<RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures)
private org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface getRsAdmin() throws IOException
IOException
protected final ServerName getServerName()
private boolean scheduleForRetry(IOException e)
private long getMaxWaitTime()
private IOException unwrapException(IOException e)
public void dispatchOpenRequests(MasterProcedureEnv env, List<RSProcedureDispatcher.RegionOpenOperation> operations)
dispatchOpenRequests
in interface RSProcedureDispatcher.RemoteProcedureResolver
public void dispatchCloseRequests(MasterProcedureEnv env, List<RSProcedureDispatcher.RegionCloseOperation> operations)
dispatchCloseRequests
in interface RSProcedureDispatcher.RemoteProcedureResolver
public void dispatchServerOperations(MasterProcedureEnv env, List<RSProcedureDispatcher.ServerOperation> operations)
dispatchServerOperations
in interface RSProcedureDispatcher.RemoteProcedureResolver
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
IOException
protected final void remoteCallFailed(MasterProcedureEnv env, IOException e)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.