org.apache.hadoop.hbase.ipc

Class FastPathBalancedQueueRpcExecutor

java.lang.Object

org.apache.hadoop.hbase.ipc.RpcExecutor

org.apache.hadoop.hbase.ipc.BalancedQueueRpcExecutor

org.apache.hadoop.hbase.ipc.FastPathBalancedQueueRpcExecutor

@InterfaceAudience.Private
public class FastPathBalancedQueueRpcExecutor
extends BalancedQueueRpcExecutor

Balanced queue executor with a fastpath. Because this is FIFO, it has no respect for ordering so a fast path skipping the queuing of Calls if an Handler is available, is possible. Just pass the Call direct to waiting Handler thread. Try to keep the hot Handlers bubbling rather than let them go cold and lose context. Idea taken from Apace Kudu (incubating). See https://gerrit.cloudera.org/#/c/2938/7/src/kudu/rpc/service_queue.h

Nested Class Summary

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

RpcExecutor.Handler, RpcExecutor.QueueBalancer

Field Summary

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

queues

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

currentQueueLimit, DEFAULT_CALL_QUEUE_SIZE_HARD_LIMIT

Constructor Summary

Constructors

Constructor and Description
FastPathBalancedQueueRpcExecutor(java.lang.String name, int handlerCount, int numCallQueues, Configuration conf, Abortable abortable, java.lang.Class<? extends java.util.concurrent.BlockingQueue> queueClass, java.lang.Object... args)
FastPathBalancedQueueRpcExecutor(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
protected RpcExecutor.Handler	getHandler(java.lang.String name, double handlerFailureThreshhold, java.util.concurrent.BlockingQueue<CallRunner> q) Override if providing alternate Handler implementation.

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

getQueueLength, getQueues, initializeQueues

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

FastPathBalancedQueueRpcExecutor

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

FastPathBalancedQueueRpcExecutor

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

Method Detail

getHandler

protected RpcExecutor.Handler getHandler(java.lang.String name,
                                         double handlerFailureThreshhold,
                                         java.util.concurrent.BlockingQueue<CallRunner> q)

Description copied from class: RpcExecutor

Override if providing alternate Handler implementation.

Overrides:

getHandler in class RpcExecutor

dispatch

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

Description copied from class: RpcExecutor

Add the request to the executor queue

Overrides:

dispatch in class BalancedQueueRpcExecutor

Throws:

java.lang.InterruptedException