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

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	dispatch(CallRunner callTask) Add the request to the executor queue
int	getQueueLength() Returns the length of the pending queue
protected List<BlockingQueue<CallRunner>>	getQueues() Returns the list of request queues
protected void	startHandlers(int port)

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

consumerLoop, getActiveHandlerCount, getBalancer, 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(String name,
                  int handlerCount,
                  int numQueues,
                  float readShare,
                  int maxQueueLength,
                  org.apache.hadoop.conf.Configuration conf,
                  Abortable abortable)

RWQueueRpcExecutor

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

RWQueueRpcExecutor

public RWQueueRpcExecutor(String name,
                  int handlerCount,
                  int numQueues,
                  float readShare,
                  float scanShare,
                  int maxQueueLength,
                  org.apache.hadoop.conf.Configuration conf,
                  Abortable abortable)

RWQueueRpcExecutor

public RWQueueRpcExecutor(String name,
                  int handlerCount,
                  int numQueues,
                  float readShare,
                  int maxQueueLength,
                  org.apache.hadoop.conf.Configuration conf,
                  Abortable abortable,
                  Class<? extends BlockingQueue> readQueueClass,
                  Object... readQueueInitArgs)

RWQueueRpcExecutor

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

RWQueueRpcExecutor

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

RWQueueRpcExecutor

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

Method Detail

startHandlers

protected void startHandlers(int port)

Overrides:

startHandlers in class RpcExecutor

dispatch

public void dispatch(CallRunner callTask)
              throws InterruptedException

Description copied from class: RpcExecutor

Add the request to the executor queue

Specified by:

dispatch in class RpcExecutor

Throws:

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 List<BlockingQueue<CallRunner>> getQueues()

Description copied from class: RpcExecutor

Returns the list of request queues

Specified by:

getQueues in class RpcExecutor