RpcExecutor (Apache HBase 1.2.12 API)

java.lang.Object
- org.apache.hadoop.hbase.ipc.RpcExecutor

Direct Known Subclasses:: BalancedQueueRpcExecutor, RWQueueRpcExecutor

@InterfaceAudience.Private
@InterfaceStability.Evolving
public abstract class RpcExecutor
extends Object

Nested Class Summary

Nested Classes
Modifier and Type	Class and Description
`static class`	`RpcExecutor.QueueBalancer`
`private static class`	`RpcExecutor.RandomQueueBalancer` Queue balancer that just randomly selects a queue in the range [0, num queues).

Field Summary

Fields
Modifier and Type	Field and Description
`private Abortable`	`abortable`
`private AtomicInteger`	`activeHandlerCount`
`private org.apache.hadoop.conf.Configuration`	`conf`
`private AtomicInteger`	`failedHandlerCount`
`private int`	`handlerCount`
`private List<Thread>`	`handlers`
`private static org.apache.commons.logging.Log`	`LOG`
`private String`	`name`
`private static RpcExecutor.QueueBalancer`	`ONE_QUEUE` All requests go to the first queue, at index 0
`private boolean`	`running`

Constructor Summary

Constructors
Constructor and Description
`RpcExecutor(String name, int handlerCount)`
`RpcExecutor(String name, int handlerCount, org.apache.hadoop.conf.Configuration conf, Abortable abortable)`

Method Summary

Methods
Modifier and Type	Method and Description
`protected void`	`consumerLoop(BlockingQueue<CallRunner> myQueue)`
`abstract boolean`	`dispatch(CallRunner callTask)` Add the request to the executor queue
`int`	`getActiveHandlerCount()`
`static RpcExecutor.QueueBalancer`	`getBalancer(int queueSize)`
`abstract int`	`getQueueLength()` Returns the length of the pending queue
`protected abstract List<BlockingQueue<CallRunner>>`	`getQueues()` Returns the list of request queues
`void`	`start(int port)`
`protected void`	`startHandlers(int port)`
`protected void`	`startHandlers(String nameSuffix, int numHandlers, List<BlockingQueue<CallRunner>> callQueues, int qindex, int qsize, int port)`
`void`	`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

activeHandlerCount

private final AtomicInteger activeHandlerCount

handlers
```
private final List<Thread> handlers
```

handlerCount
```
private final int handlerCount
```

name
```
private final String name
```

failedHandlerCount

private final AtomicInteger failedHandlerCount

running
```
private boolean running
```

conf

private org.apache.hadoop.conf.Configuration conf

abortable
```
private Abortable abortable
```

ONE_QUEUE
```
private static RpcExecutor.QueueBalancer ONE_QUEUE
```
All requests go to the first queue, at index 0

Constructor Detail

RpcExecutor

public RpcExecutor(String name,
           int handlerCount)

RpcExecutor

public RpcExecutor(String name,
           int handlerCount,
           org.apache.hadoop.conf.Configuration conf,
           Abortable abortable)

Method Detail

start
```
public void start(int port)
```

stop
```
public void stop()
```

getActiveHandlerCount
```
public int getActiveHandlerCount()
```

getQueueLength
```
public abstract int getQueueLength()
```
Returns the length of the pending queue

dispatch

public abstract boolean dispatch(CallRunner callTask)
                          throws InterruptedException

Add the request to the executor queue

Throws:: InterruptedException

getQueues

protected abstract List<BlockingQueue<CallRunner>> getQueues()

Returns the list of request queues

startHandlers

protected void startHandlers(int port)

startHandlers

protected void startHandlers(String nameSuffix,
                 int numHandlers,
                 List<BlockingQueue<CallRunner>> callQueues,
                 int qindex,
                 int qsize,
                 int port)

consumerLoop

protected void consumerLoop(BlockingQueue<CallRunner> myQueue)

getBalancer

public static RpcExecutor.QueueBalancer getBalancer(int queueSize)

Class RpcExecutor

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

LOG

activeHandlerCount

handlers

handlerCount

name

failedHandlerCount

running

conf

abortable

ONE_QUEUE

Constructor Detail

RpcExecutor

RpcExecutor

Method Detail

start

stop

getActiveHandlerCount

getQueueLength

dispatch

getQueues

startHandlers

startHandlers

consumerLoop

getBalancer