@InterfaceAudience.LimitedPrivate(value={"Coprocesssor","Phoenix"}) @InterfaceStability.Evolving public class BalancedQueueRpcExecutor extends RpcExecutor
RpcExecutor that will balance requests evenly across all its queues, but still remains
efficient with a single queue via an inlinable queue balancing mechanism. Defaults to FIFO but
you can pass an alternate queue class to use.RpcExecutor.Handler, RpcExecutor.QueueBalancerCALL_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| Constructor and Description |
|---|
BalancedQueueRpcExecutor(String name,
int handlerCount,
int numQueues,
Class<? extends BlockingQueue> queueClass,
Object... initargs)
Deprecated.
|
BalancedQueueRpcExecutor(String name,
int handlerCount,
int numQueues,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable,
Class<? extends BlockingQueue> queueClass,
Object... initargs)
Deprecated.
|
BalancedQueueRpcExecutor(String name,
int handlerCount,
int numQueues,
int maxQueueLength)
Deprecated.
|
BalancedQueueRpcExecutor(String name,
int handlerCount,
int numQueues,
int maxQueueLength,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable)
Deprecated.
|
BalancedQueueRpcExecutor(String name,
int handlerCount,
int maxQueueLength,
PriorityFunction priority,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable) |
BalancedQueueRpcExecutor(String name,
int handlerCount,
String callQueueType,
int maxQueueLength,
PriorityFunction priority,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
dispatch(CallRunner callTask)
Add the request to the executor queue
|
protected void |
initializeQueues(int numQueues,
Class<? extends BlockingQueue> queueClass,
Object... initargs)
Deprecated.
|
computeNumCallQueues, getActiveHandlerCount, getActiveReadHandlerCount, getActiveScanHandlerCount, getActiveWriteHandlerCount, getBalancer, getHandler, getName, getNumGeneralCallsDropped, getNumLifoModeSwitches, getQueueLength, getQueues, getReadQueueLength, getScanQueueLength, getWriteQueueLength, initializeQueues, isCodelQueueType, isDeadlineQueueType, isFifoQueueType, onConfigurationChange, resizeQueues, start, startHandlers, startHandlers, stoppublic BalancedQueueRpcExecutor(String name, int handlerCount, int maxQueueLength, PriorityFunction priority, org.apache.hadoop.conf.Configuration conf, Abortable abortable)
public BalancedQueueRpcExecutor(String name, int handlerCount, String callQueueType, int maxQueueLength, PriorityFunction priority, org.apache.hadoop.conf.Configuration conf, Abortable abortable)
@Deprecated public BalancedQueueRpcExecutor(String name, int handlerCount, int numQueues, int maxQueueLength)
@Deprecated public BalancedQueueRpcExecutor(String name, int handlerCount, int numQueues, int maxQueueLength, org.apache.hadoop.conf.Configuration conf, Abortable abortable)
@Deprecated public BalancedQueueRpcExecutor(String name, int handlerCount, int numQueues, Class<? extends BlockingQueue> queueClass, Object... initargs)
@Deprecated public BalancedQueueRpcExecutor(String name, int handlerCount, int numQueues, org.apache.hadoop.conf.Configuration conf, Abortable abortable, Class<? extends BlockingQueue> queueClass, Object... initargs)
@Deprecated protected void initializeQueues(int numQueues, Class<? extends BlockingQueue> queueClass, Object... initargs)
public boolean dispatch(CallRunner callTask) throws InterruptedException
RpcExecutordispatch in class RpcExecutorInterruptedExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.