RWQueueRpcExecutor (Apache HBase 1.4.11 API)

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
Modifier and Type Field and Description

static String CALL_QUEUE_READ_SHARE_CONF_KEY

static String CALL_QUEUE_SCAN_SHARE_CONF_KEY
- Fields inherited from class org.apache.hadoop.hbase.ipc.RpcExecutor
  CALL_QUEUE_CODEL_DEFAULT_INTERVAL, CALL_QUEUE_CODEL_DEFAULT_LIFO_THRESHOLD, CALL_QUEUE_CODEL_DEFAULT_TARGET_DELAY, CALL_QUEUE_CODEL_INTERVAL, CALL_QUEUE_CODEL_LIFO_THRESHOLD, CALL_QUEUE_CODEL_TARGET_DELAY, CALL_QUEUE_HANDLER_FACTOR_CONF_KEY, CALL_QUEUE_TYPE_CODEL_CONF_VALUE, CALL_QUEUE_TYPE_CONF_DEFAULT, CALL_QUEUE_TYPE_CONF_KEY, CALL_QUEUE_TYPE_DEADLINE_CONF_VALUE, CALL_QUEUE_TYPE_FIFO_CONF_VALUE, currentQueueLimit, DEFAULT_CALL_QUEUE_SIZE_HARD_LIMIT, numCallQueues, QUEUE_MAX_CALL_DELAY_CONF_KEY, queues

Fields
Modifier and Type	Field and Description
`static String`	`CALL_QUEUE_READ_SHARE_CONF_KEY`
`static String`	`CALL_QUEUE_SCAN_SHARE_CONF_KEY`

Constructor Summary

Constructors
Constructor and Description
`RWQueueRpcExecutor(String name, int handlerCount, int numQueues, float readShare, float scanShare, Class<? extends BlockingQueue> writeQueueClass, Object[] writeQueueInitArgs, Class<? extends BlockingQueue> readQueueClass, Object[] readQueueInitArgs)` Deprecated.
`RWQueueRpcExecutor(String name, int handlerCount, int numQueues, float readShare, float scanShare, int maxQueueLength)` Deprecated.
`RWQueueRpcExecutor(String name, int handlerCount, int numQueues, float readShare, float scanShare, int maxQueueLength, org.apache.hadoop.conf.Configuration conf, Abortable abortable)` Deprecated.
`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)` Deprecated.
`RWQueueRpcExecutor(String name, int handlerCount, int numQueues, float readShare, int maxQueueLength, org.apache.hadoop.conf.Configuration conf, Abortable abortable)` Deprecated.
`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)` Deprecated.
`RWQueueRpcExecutor(String name, int writeHandlers, int readHandlers, int numWriteQueues, int numReadQueues, Class<? extends BlockingQueue> writeQueueClass, Object[] writeQueueInitArgs, Class<? extends BlockingQueue> readQueueClass, Object[] readQueueInitArgs)` Deprecated.
`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)` Deprecated.
`RWQueueRpcExecutor(String name, int handlerCount, int maxQueueLength, PriorityFunction priority, org.apache.hadoop.conf.Configuration conf, Abortable abortable)`

Method Summary

Methods
Modifier and Type	Method and Description
`protected int`	`computeNumCallQueues(int handlerCount, float callQueuesHandlersFactor)`
`boolean`	`dispatch(CallRunner callTask)` Add the request to the executor queue
`int`	`getActiveHandlerCount()`
`int`	`getActiveReadHandlerCount()`
`int`	`getActiveScanHandlerCount()`
`int`	`getActiveWriteHandlerCount()`
`int`	`getReadQueueLength()`
`int`	`getScanQueueLength()`
`int`	`getWriteQueueLength()`
`protected void`	`startHandlers(int port)`

Methods inherited from class org.apache.hadoop.hbase.ipc.RpcExecutor
getBalancer, getHandler, getName, getNumGeneralCallsDropped, getNumLifoModeSwitches, getQueueLength, getQueues, initializeQueues, isCodelQueueType, isDeadlineQueueType, isFifoQueueType, onConfigurationChange, resizeQueues, start, startHandlers, stop

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail
- CALL_QUEUE_READ_SHARE_CONF_KEY
```
public static final String CALL_QUEUE_READ_SHARE_CONF_KEY
```
  See Also:
  Constant Field Values
- CALL_QUEUE_SCAN_SHARE_CONF_KEY
```
public static final String CALL_QUEUE_SCAN_SHARE_CONF_KEY
```
  See Also:
  Constant Field Values

Constructor Detail

RWQueueRpcExecutor

public RWQueueRpcExecutor(String name,
                  int handlerCount,
                  int maxQueueLength,
                  PriorityFunction priority,
                  org.apache.hadoop.conf.Configuration conf,
                  Abortable abortable)

RWQueueRpcExecutor

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

Deprecated.

RWQueueRpcExecutor

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

Deprecated.

RWQueueRpcExecutor

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

Deprecated.

RWQueueRpcExecutor

@Deprecated
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)

Deprecated.

RWQueueRpcExecutor

@Deprecated
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)

Deprecated.

RWQueueRpcExecutor

@Deprecated
public RWQueueRpcExecutor(String name,
                             int handlerCount,
                             int numQueues,
                             float readShare,
                             float scanShare,
                             Class<? extends BlockingQueue> writeQueueClass,
                             Object[] writeQueueInitArgs,
                             Class<? extends BlockingQueue> readQueueClass,
                             Object[] readQueueInitArgs)

Deprecated.

RWQueueRpcExecutor

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

Deprecated.

RWQueueRpcExecutor

@Deprecated
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)

Deprecated.

Method Detail
- computeNumCallQueues
```
protected int computeNumCallQueues(int handlerCount,
                       float callQueuesHandlersFactor)
```
  Overrides:
  
  computeNumCallQueues in class RpcExecutor
- startHandlers
```
protected void startHandlers(int port)
```
  Overrides:
  
  startHandlers in class RpcExecutor
- dispatch
```
public boolean 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
- getWriteQueueLength
```
public int getWriteQueueLength()
```
  Overrides:
  
  getWriteQueueLength in class RpcExecutor
- getReadQueueLength
```
public int getReadQueueLength()
```
  Overrides:
  
  getReadQueueLength in class RpcExecutor
- getScanQueueLength
```
public int getScanQueueLength()
```
  Overrides:
  
  getScanQueueLength in class RpcExecutor
- getActiveHandlerCount
```
public int getActiveHandlerCount()
```
  Overrides:
  
  getActiveHandlerCount in class RpcExecutor
- getActiveWriteHandlerCount
```
public int getActiveWriteHandlerCount()
```
  Overrides:
  
  getActiveWriteHandlerCount in class RpcExecutor
- getActiveReadHandlerCount
```
public int getActiveReadHandlerCount()
```
  Overrides:
  
  getActiveReadHandlerCount in class RpcExecutor
- getActiveScanHandlerCount
```
public int getActiveScanHandlerCount()
```
  Overrides:
  
  getActiveScanHandlerCount in class RpcExecutor

Class RWQueueRpcExecutor

Nested Class Summary

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

Field Summary

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

Constructor Summary

Method Summary

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

Methods inherited from class java.lang.Object

Field Detail

CALL_QUEUE_READ_SHARE_CONF_KEY

CALL_QUEUE_SCAN_SHARE_CONF_KEY

Constructor Detail

RWQueueRpcExecutor

RWQueueRpcExecutor

RWQueueRpcExecutor

RWQueueRpcExecutor

RWQueueRpcExecutor

RWQueueRpcExecutor

RWQueueRpcExecutor

RWQueueRpcExecutor

RWQueueRpcExecutor

Method Detail

computeNumCallQueues

startHandlers

dispatch

getWriteQueueLength

getReadQueueLength

getScanQueueLength

getActiveHandlerCount

getActiveWriteHandlerCount

getActiveReadHandlerCount

getActiveScanHandlerCount