org.apache.hadoop.hbase.ipc

Class RWQueueRpcExecutor

java.lang.Object

org.apache.hadoop.hbase.ipc.RpcExecutor

org.apache.hadoop.hbase.ipc.RWQueueRpcExecutor

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

RPC Executor that uses different queues for reads and writes. With the options to use different queues/executors for gets and scans. Each handler has its own queue and there is no stealing.

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.RpcExecutor

currentQueueLimit, DEFAULT_CALL_QUEUE_SIZE_HARD_LIMIT

Constructor Summary

Constructors

Constructor and Description
RWQueueRpcExecutor(java.lang.String name, int handlerCount, int numQueues, float readShare, float scanShare, java.lang.Class<? extends java.util.concurrent.BlockingQueue> writeQueueClass, java.lang.Object[] writeQueueInitArgs, java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass, java.lang.Object[] readQueueInitArgs)
RWQueueRpcExecutor(java.lang.String name, int handlerCount, int numQueues, float readShare, float scanShare, int maxQueueLength)
RWQueueRpcExecutor(java.lang.String name, int handlerCount, int numQueues, float readShare, float scanShare, int maxQueueLength, Configuration conf, Abortable abortable)
RWQueueRpcExecutor(java.lang.String name, int handlerCount, int numQueues, float readShare, float scanShare, int maxQueueLength, Configuration conf, Abortable abortable, java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass, java.lang.Object... readQueueInitArgs)
RWQueueRpcExecutor(java.lang.String name, int handlerCount, int numQueues, float readShare, int maxQueueLength, Configuration conf, Abortable abortable)
RWQueueRpcExecutor(java.lang.String name, int handlerCount, int numQueues, float readShare, int maxQueueLength, Configuration conf, Abortable abortable, java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass, java.lang.Object... readQueueInitArgs)
RWQueueRpcExecutor(java.lang.String name, int writeHandlers, int readHandlers, int numWriteQueues, int numReadQueues, java.lang.Class<? extends java.util.concurrent.BlockingQueue> writeQueueClass, java.lang.Object[] writeQueueInitArgs, java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass, java.lang.Object[] readQueueInitArgs)
RWQueueRpcExecutor(java.lang.String name, int writeHandlers, int readHandlers, int numWriteQueues, int numReadQueues, float scanShare, java.lang.Class<? extends java.util.concurrent.BlockingQueue> writeQueueClass, java.lang.Object[] writeQueueInitArgs, java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass, java.lang.Object[] readQueueInitArgs)

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
protected java.util.List<java.util.concurrent.BlockingQueue<CallRunner>>	getQueues() Returns the list of request queues
protected void	startHandlers(int port)

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

RWQueueRpcExecutor

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

RWQueueRpcExecutor

public RWQueueRpcExecutor(java.lang.String name,
                          int handlerCount,
                          int numQueues,
                          float readShare,
                          float scanShare,
                          int maxQueueLength)

RWQueueRpcExecutor

public RWQueueRpcExecutor(java.lang.String name,
                          int handlerCount,
                          int numQueues,
                          float readShare,
                          float scanShare,
                          int maxQueueLength,
                          Configuration conf,
                          Abortable abortable)

RWQueueRpcExecutor

public RWQueueRpcExecutor(java.lang.String name,
                          int handlerCount,
                          int numQueues,
                          float readShare,
                          int maxQueueLength,
                          Configuration conf,
                          Abortable abortable,
                          java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass,
                          java.lang.Object... readQueueInitArgs)

RWQueueRpcExecutor

public RWQueueRpcExecutor(java.lang.String name,
                          int handlerCount,
                          int numQueues,
                          float readShare,
                          float scanShare,
                          int maxQueueLength,
                          Configuration conf,
                          Abortable abortable,
                          java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass,
                          java.lang.Object... readQueueInitArgs)

RWQueueRpcExecutor

public RWQueueRpcExecutor(java.lang.String name,
                          int handlerCount,
                          int numQueues,
                          float readShare,
                          float scanShare,
                          java.lang.Class<? extends java.util.concurrent.BlockingQueue> writeQueueClass,
                          java.lang.Object[] writeQueueInitArgs,
                          java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass,
                          java.lang.Object[] readQueueInitArgs)

RWQueueRpcExecutor

public RWQueueRpcExecutor(java.lang.String name,
                          int writeHandlers,
                          int readHandlers,
                          int numWriteQueues,
                          int numReadQueues,
                          java.lang.Class<? extends java.util.concurrent.BlockingQueue> writeQueueClass,
                          java.lang.Object[] writeQueueInitArgs,
                          java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass,
                          java.lang.Object[] readQueueInitArgs)

RWQueueRpcExecutor

public RWQueueRpcExecutor(java.lang.String name,
                          int writeHandlers,
                          int readHandlers,
                          int numWriteQueues,
                          int numReadQueues,
                          float scanShare,
                          java.lang.Class<? extends java.util.concurrent.BlockingQueue> writeQueueClass,
                          java.lang.Object[] writeQueueInitArgs,
                          java.lang.Class<? extends java.util.concurrent.BlockingQueue> readQueueClass,
                          java.lang.Object[] readQueueInitArgs)

Method Detail

startHandlers

protected void startHandlers(int port)

Overrides:

startHandlers 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

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

protected 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