org.apache.hadoop.hbase.ipc

Class BalancedQueueRpcExecutor

java.lang.Object

org.apache.hadoop.hbase.ipc.RpcExecutor

org.apache.hadoop.hbase.ipc.BalancedQueueRpcExecutor

Direct Known Subclasses:

FastPathBalancedQueueRpcExecutor

@InterfaceAudience.LimitedPrivate(value={"Coprocesssor","Phoenix"})
 @InterfaceStability.Evolving
public class BalancedQueueRpcExecutor
extends RpcExecutor

An RpcExecutor that will balance requests evenly across all its queues, but still remains efficient with a single queue via an inlinable queue balancing mechanism. Defaults to FIFO but you can pass an alternate queue class to use.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.ipc.RpcExecutor

RpcExecutor.Handler, RpcExecutor.QueueBalancer

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.List<java.util.concurrent.BlockingQueue<CallRunner>>	queues

Fields inherited from class org.apache.hadoop.hbase.ipc.RpcExecutor

currentQueueLimit, DEFAULT_CALL_QUEUE_SIZE_HARD_LIMIT

Constructor Summary

Constructors

Constructor and Description
BalancedQueueRpcExecutor(java.lang.String name, int handlerCount, int numQueues, java.lang.Class<? extends java.util.concurrent.BlockingQueue> queueClass, java.lang.Object... initargs)
BalancedQueueRpcExecutor(java.lang.String name, int handlerCount, int numQueues, Configuration conf, Abortable abortable, java.lang.Class<? extends java.util.concurrent.BlockingQueue> queueClass, java.lang.Object... initargs)
BalancedQueueRpcExecutor(java.lang.String name, int handlerCount, int numQueues, int maxQueueLength)
BalancedQueueRpcExecutor(java.lang.String name, int handlerCount, int numQueues, int maxQueueLength, Configuration conf, Abortable abortable)

Method Summary

Modifier and Type	Method and Description
boolean	dispatch(CallRunner callTask) Add the request to the executor queue
int	getQueueLength() Returns the length of the pending queue
java.util.List<java.util.concurrent.BlockingQueue<CallRunner>>	getQueues() Returns the list of request queues
protected void	initializeQueues(int numQueues, java.lang.Class<? extends java.util.concurrent.BlockingQueue> queueClass, java.lang.Object... initargs)

Methods inherited from class org.apache.hadoop.hbase.ipc.RpcExecutor

getActiveHandlerCount, getBalancer, getHandler, resizeQueues, start, startHandlers, startHandlers, stop

Methods inherited from class java.lang.Object

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

Field Detail

queues

protected final java.util.List<java.util.concurrent.BlockingQueue<CallRunner>> queues

Constructor Detail

BalancedQueueRpcExecutor

public BalancedQueueRpcExecutor(java.lang.String name,
                                int handlerCount,
                                int numQueues,
                                int maxQueueLength)

BalancedQueueRpcExecutor

public BalancedQueueRpcExecutor(java.lang.String name,
                                int handlerCount,
                                int numQueues,
                                int maxQueueLength,
                                Configuration conf,
                                Abortable abortable)

BalancedQueueRpcExecutor

public BalancedQueueRpcExecutor(java.lang.String name,
                                int handlerCount,
                                int numQueues,
                                java.lang.Class<? extends java.util.concurrent.BlockingQueue> queueClass,
                                java.lang.Object... initargs)

BalancedQueueRpcExecutor

public BalancedQueueRpcExecutor(java.lang.String name,
                                int handlerCount,
                                int numQueues,
                                Configuration conf,
                                Abortable abortable,
                                java.lang.Class<? extends java.util.concurrent.BlockingQueue> queueClass,
                                java.lang.Object... initargs)

Method Detail

initializeQueues

protected void initializeQueues(int numQueues,
                                java.lang.Class<? extends java.util.concurrent.BlockingQueue> queueClass,
                                java.lang.Object... initargs)

dispatch

public boolean dispatch(CallRunner callTask)
                 throws java.lang.InterruptedException

Description copied from class: RpcExecutor

Add the request to the executor queue

Specified by:

dispatch in class RpcExecutor

Throws:

java.lang.InterruptedException

getQueueLength

public int getQueueLength()

Description copied from class: RpcExecutor

Returns the length of the pending queue

Specified by:

getQueueLength in class RpcExecutor

getQueues

public java.util.List<java.util.concurrent.BlockingQueue<CallRunner>> getQueues()

Description copied from class: RpcExecutor

Returns the list of request queues

Specified by:

getQueues in class RpcExecutor