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. Each handler has its own queue and there is no stealing.

Constructor Summary

Constructors

Constructor and Description
RWQueueRpcExecutor(String name, int handlerCount, int numQueues, float readShare, int maxQueueLength)
RWQueueRpcExecutor(String name, int handlerCount, int numQueues, float readShare, int maxQueueLength, 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)

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, 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)

RWQueueRpcExecutor

public RWQueueRpcExecutor(String name,
                  int handlerCount,
                  int numQueues,
                  float readShare,
                  int maxQueueLength,
                  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)

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