protected class TestAssignmentManagerBase.SocketTimeoutRsExecutor extends TestAssignmentManagerBase.GoodRsExecutor
| Modifier and Type | Field and Description |
|---|---|
private org.apache.hadoop.hbase.ServerName |
lastServer |
private int |
maxServerRetries |
private int |
maxSocketTimeoutRetries |
private int |
serverRetries |
private int |
sockTimeoutRetries |
| Constructor and Description |
|---|
SocketTimeoutRsExecutor(int maxSocketTimeoutRetries,
int maxServerRetries) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse |
sendRequest(org.apache.hadoop.hbase.ServerName server,
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest req) |
execCloseRegion, execOpenRegionprivate final int maxSocketTimeoutRetries
private final int maxServerRetries
private org.apache.hadoop.hbase.ServerName lastServer
private int sockTimeoutRetries
private int serverRetries
public SocketTimeoutRsExecutor(int maxSocketTimeoutRetries, int maxServerRetries)
public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse sendRequest(org.apache.hadoop.hbase.ServerName server, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest req) throws IOException
sendRequest in interface TestAssignmentManagerBase.MockRSExecutorsendRequest in class TestAssignmentManagerBase.NoopRsExecutorIOExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.