Package org.apache.hadoop.hbase.master.assignment

Class TestAssignmentManagerBase.TimeoutThenCallQueueTooBigRsExecutor

java.lang.Object

org.apache.hadoop.hbase.master.assignment.TestAssignmentManagerBase.NoopRsExecutor

org.apache.hadoop.hbase.master.assignment.TestAssignmentManagerBase.GoodRsExecutor

org.apache.hadoop.hbase.master.assignment.TestAssignmentManagerBase.TimeoutThenCallQueueTooBigRsExecutor

All Implemented Interfaces:

TestAssignmentManagerBase.MockRSExecutor

Enclosing class:

TestAssignmentManagerBase

protected class TestAssignmentManagerBase.TimeoutThenCallQueueTooBigRsExecutor
extends TestAssignmentManagerBase.GoodRsExecutor

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.hbase.ServerName	lastServer
private final int	queueFullTimes
private int	retries

Constructor Summary

Constructors

Constructor	Description
TimeoutThenCallQueueTooBigRsExecutor(int queueFullTimes)

Method Summary

Modifier and Type	Method	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)

Methods inherited from class org.apache.hadoop.hbase.master.assignment.TestAssignmentManagerBase.GoodRsExecutor

execCloseRegion, execOpenRegion

Methods inherited from class java.lang.Object

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

Field Details

queueFullTimes

private final int queueFullTimes

retries

private int retries

lastServer

private org.apache.hadoop.hbase.ServerName lastServer

Constructor Details

TimeoutThenCallQueueTooBigRsExecutor

public TimeoutThenCallQueueTooBigRsExecutor(int queueFullTimes)

Method Details

sendRequest

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

Specified by:

sendRequest in interface TestAssignmentManagerBase.MockRSExecutor

Overrides:

sendRequest in class TestAssignmentManagerBase.NoopRsExecutor

Throws:

IOException