protected class TestAssignmentManagerBase.SocketTimeoutRsExecutor extends TestAssignmentManagerBase.GoodRsExecutor
Modifier and Type | Field and Description |
---|---|
private org.apache.hadoop.hbase.ServerName |
lastServer |
private int |
retries |
private int |
timeoutTimes |
Constructor and Description |
---|
SocketTimeoutRsExecutor(int timeoutTimes) |
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, execOpenRegion
private final int timeoutTimes
private org.apache.hadoop.hbase.ServerName lastServer
private int retries
public SocketTimeoutRsExecutor(int timeoutTimes)
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.MockRSExecutor
sendRequest
in class TestAssignmentManagerBase.NoopRsExecutor
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.