org.apache.hadoop.hbase.ipc

Class RpcExecutor.RandomQueueBalancer

java.lang.Object

org.apache.hadoop.hbase.ipc.RpcExecutor.QueueBalancer

org.apache.hadoop.hbase.ipc.RpcExecutor.RandomQueueBalancer

Enclosing class:

RpcExecutor

private static class RpcExecutor.RandomQueueBalancer
extends RpcExecutor.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 int	queueSize

Constructor Summary

Constructors

Constructor and Description
RandomQueueBalancer(int queueSize)

Method Summary

Modifier and Type	Method and Description
int	getNextQueue()

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

Constructor Detail

RandomQueueBalancer

public RandomQueueBalancer(int queueSize)

Method Detail

getNextQueue

public int getNextQueue()

Specified by:

getNextQueue in class RpcExecutor.QueueBalancer

Returns:

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