@InterfaceAudience.Private @InterfaceStability.Evolving public class MetaRWQueueRpcExecutor extends RWQueueRpcExecutor
Modifier and Type | Field and Description |
---|---|
static float |
DEFAULT_META_CALL_QUEUE_READ_SHARE |
static String |
META_CALL_QUEUE_READ_SHARE_CONF_KEY |
static String |
META_CALL_QUEUE_SCAN_SHARE_CONF_KEY |
CALL_QUEUE_READ_SHARE_CONF_KEY, CALL_QUEUE_SCAN_SHARE_CONF_KEY
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_QUEUE_BALANCER_CLASS, CALL_QUEUE_QUEUE_BALANCER_CLASS_DEFAULT, 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, CALL_QUEUE_TYPE_PLUGGABLE_CONF_VALUE, currentQueueLimit, DEFAULT_CALL_QUEUE_SIZE_HARD_LIMIT, numCallQueues, PLUGGABLE_CALL_QUEUE_CLASS_NAME, PLUGGABLE_CALL_QUEUE_WITH_FAST_PATH_ENABLED, QUEUE_MAX_CALL_DELAY_CONF_KEY, queues
Constructor and Description |
---|
MetaRWQueueRpcExecutor(String name,
int handlerCount,
int maxQueueLength,
PriorityFunction priority,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable) |
Modifier and Type | Method and Description |
---|---|
protected float |
getReadShare(org.apache.hadoop.conf.Configuration conf) |
protected float |
getScanShare(org.apache.hadoop.conf.Configuration conf) |
computeNumCallQueues, dispatch, dispatchTo, getActiveHandlerCount, getActiveReadHandlerCount, getActiveScanHandlerCount, getActiveWriteHandlerCount, getReadBalancer, getReadQueueLength, getScanBalancer, getScanQueueLength, getWriteBalancer, getWriteQueueLength, isWriteRequest, onConfigurationChange, shouldDispatchToScanQueue, startHandlers
getBalancer, getCallQueueCountsSummary, getCallQueueSizeSummary, getHandler, getName, getNumGeneralCallsDropped, getNumLifoModeSwitches, getQueueLength, getQueues, initializeQueues, isCodelQueueType, isDeadlineQueueType, isFifoQueueType, isPluggableQueueType, isPluggableQueueWithFastPath, resizeQueues, start, startHandlers, stop
public static final String META_CALL_QUEUE_READ_SHARE_CONF_KEY
public static final String META_CALL_QUEUE_SCAN_SHARE_CONF_KEY
public static final float DEFAULT_META_CALL_QUEUE_READ_SHARE
public MetaRWQueueRpcExecutor(String name, int handlerCount, int maxQueueLength, PriorityFunction priority, org.apache.hadoop.conf.Configuration conf, Abortable abortable)
protected float getReadShare(org.apache.hadoop.conf.Configuration conf)
getReadShare
in class RWQueueRpcExecutor
protected float getScanShare(org.apache.hadoop.conf.Configuration conf)
getScanShare
in class RWQueueRpcExecutor
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.