org.apache.hadoop.hbase.ipc

Class RandomQueueBalancer

java.lang.Object

org.apache.hadoop.hbase.ipc.RandomQueueBalancer

All Implemented Interfaces:

QueueBalancer

@InterfaceAudience.Private
 @InterfaceStability.Stable
public class RandomQueueBalancer
extends Object
implements QueueBalancer

Queue balancer that just randomly selects a queue in the range [0, num queues).

Field Summary

Fields

Modifier and Type	Field and Description
private List<BlockingQueue<CallRunner>>	queues
private int	queueSize

Constructor Summary

Constructors

Constructor and Description
RandomQueueBalancer(org.apache.hadoop.conf.Configuration conf, String executorName, List<BlockingQueue<CallRunner>> queues)

Method Summary

Modifier and Type	Method and Description
int	getNextQueue(CallRunner callRunner) Returns the index of the next queue to which a request should be inserted
(package private) List<BlockingQueue<CallRunner>>	getQueues() Exposed for use in tests

Methods inherited from class java.lang.Object

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

Field Detail

queueSize

private final int queueSize

queues

private final List<BlockingQueue<CallRunner>> queues

Constructor Detail

RandomQueueBalancer

public RandomQueueBalancer(org.apache.hadoop.conf.Configuration conf,
                           String executorName,
                           List<BlockingQueue<CallRunner>> queues)

Method Detail

getNextQueue

public int getNextQueue(CallRunner callRunner)

Description copied from interface: QueueBalancer

Returns the index of the next queue to which a request should be inserted

Specified by:

getNextQueue in interface QueueBalancer

getQueues

List<BlockingQueue<CallRunner>> getQueues()

Exposed for use in tests