RWQueueRpcExecutor (Apache HBase 1.2.12 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.QueueBalancer

Field Summary

Fields
Modifier and Type	Field and Description
`private static org.apache.commons.logging.Log`	`LOG`
`private int`	`numReadQueues`
`private int`	`numScanQueues`
`private int`	`numWriteQueues`
`private List<BlockingQueue<CallRunner>>`	`queues`
`private RpcExecutor.QueueBalancer`	`readBalancer`
`private int`	`readHandlersCount`
`private RpcExecutor.QueueBalancer`	`scanBalancer`
`private int`	`scanHandlersCount`
`private RpcExecutor.QueueBalancer`	`writeBalancer`
`private int`	`writeHandlersCount`

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
`private static int`	`calcNumReaders(int count, float readShare)`
`private static int`	`calcNumWriters(int count, float readShare)`
`boolean`	`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
`private boolean`	`isScanRequest(org.apache.hadoop.hbase.protobuf.generated.RPCProtos.RequestHeader header, com.google.protobuf.Message param)`
`private boolean`	`isWriteRequest(org.apache.hadoop.hbase.protobuf.generated.RPCProtos.RequestHeader header, com.google.protobuf.Message param)`
`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

Field Detail

LOG

private static final org.apache.commons.logging.Log LOG

queues

private final List<BlockingQueue<CallRunner>> queues

writeBalancer

private final RpcExecutor.QueueBalancer writeBalancer

readBalancer

private final RpcExecutor.QueueBalancer readBalancer

scanBalancer

private final RpcExecutor.QueueBalancer scanBalancer

writeHandlersCount
```
private final int writeHandlersCount
```

readHandlersCount
```
private final int readHandlersCount
```

scanHandlersCount
```
private final int scanHandlersCount
```

numWriteQueues
```
private final int numWriteQueues
```

numReadQueues
```
private final int numReadQueues
```

numScanQueues
```
private final int numScanQueues
```

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

isWriteRequest

private boolean isWriteRequest(org.apache.hadoop.hbase.protobuf.generated.RPCProtos.RequestHeader header,
                     com.google.protobuf.Message param)

isScanRequest

private boolean isScanRequest(org.apache.hadoop.hbase.protobuf.generated.RPCProtos.RequestHeader header,
                    com.google.protobuf.Message param)

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

calcNumWriters

private static int calcNumWriters(int count,
                 float readShare)

calcNumReaders

private static int calcNumReaders(int count,
                 float readShare)

Class RWQueueRpcExecutor

Nested Class Summary

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

Field Summary

Constructor Summary

Method Summary

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

Methods inherited from class java.lang.Object

Field Detail

LOG

queues

writeBalancer

readBalancer

scanBalancer

writeHandlersCount

readHandlersCount

scanHandlersCount

numWriteQueues

numReadQueues

numScanQueues

Constructor Detail

RWQueueRpcExecutor

RWQueueRpcExecutor

RWQueueRpcExecutor

RWQueueRpcExecutor

RWQueueRpcExecutor

RWQueueRpcExecutor

RWQueueRpcExecutor

Method Detail

startHandlers

dispatch

isWriteRequest

isScanRequest

getQueueLength

getQueues

calcNumWriters

calcNumReaders