Package org.apache.hadoop.hbase.ipc

Class MetaRWQueueRpcExecutor

java.lang.Object

org.apache.hadoop.hbase.ipc.RpcExecutor

org.apache.hadoop.hbase.ipc.RWQueueRpcExecutor

org.apache.hadoop.hbase.ipc.MetaRWQueueRpcExecutor

@Private
@Evolving
public class MetaRWQueueRpcExecutor
extends RWQueueRpcExecutor

RPC Executor that uses different queues for reads and writes for meta.

Field Summary

Fields

Modifier and Type	Field	Description
static final float	DEFAULT_META_CALL_QUEUE_READ_SHARE
private static final float	DEFAULT_META_CALL_QUEUE_SCAN_SHARE
static final String	META_CALL_QUEUE_HANDLER_FACTOR_CONF_KEY
static final String	META_CALL_QUEUE_READ_SHARE_CONF_KEY
static final String	META_CALL_QUEUE_SCAN_SHARE_CONF_KEY

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

CALL_QUEUE_READ_SHARE_CONF_KEY, 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_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 Summary

Constructors

Constructor	Description
MetaRWQueueRpcExecutor(String name, int handlerCount, int maxQueueLength, PriorityFunction priority, org.apache.hadoop.conf.Configuration conf, Abortable abortable)

Method Summary

Modifier and Type	Method	Description
boolean	dispatch(CallRunner callTask)	Add the request to the executor queue
protected float	getCallQueueHandlerFactor(org.apache.hadoop.conf.Configuration conf)
protected float	getReadShare(org.apache.hadoop.conf.Configuration conf)
protected float	getScanShare(org.apache.hadoop.conf.Configuration conf)

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

computeNumCallQueues, dispatchTo, getActiveHandlerCount, getActiveReadHandlerCount, getActiveScanHandlerCount, getActiveWriteHandlerCount, getNumScanQueues, getReadBalancer, getReadQueueLength, getScanBalancer, getScanQueueLength, getWriteBalancer, getWriteQueueLength, isWriteRequest, onConfigurationChange, shouldDispatchToScanQueue, startHandlers

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

getBalancer, getCallQueueCountsSummary, getCallQueueSizeSummary, getHandler, getName, getNumGeneralCallsDropped, getNumLifoModeSwitches, getQueueLength, getQueues, initializeQueues, isCodelQueueType, isDeadlineQueueType, isFifoQueueType, isPluggableQueueType, isPluggableQueueWithFastPath, resizeQueues, start, startHandlers, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

META_CALL_QUEUE_READ_SHARE_CONF_KEY

public static final String META_CALL_QUEUE_READ_SHARE_CONF_KEY

See Also:

• Constant Field Values

META_CALL_QUEUE_SCAN_SHARE_CONF_KEY

public static final String META_CALL_QUEUE_SCAN_SHARE_CONF_KEY

See Also:

• Constant Field Values

META_CALL_QUEUE_HANDLER_FACTOR_CONF_KEY

public static final String META_CALL_QUEUE_HANDLER_FACTOR_CONF_KEY

See Also:

• Constant Field Values

DEFAULT_META_CALL_QUEUE_READ_SHARE

public static final float DEFAULT_META_CALL_QUEUE_READ_SHARE

See Also:

• Constant Field Values

DEFAULT_META_CALL_QUEUE_SCAN_SHARE

private static final float DEFAULT_META_CALL_QUEUE_SCAN_SHARE

See Also:

• Constant Field Values

Constructor Details

MetaRWQueueRpcExecutor

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

Method Details

getReadShare

protected float getReadShare(org.apache.hadoop.conf.Configuration conf)

Overrides:

getReadShare in class RWQueueRpcExecutor

getScanShare

protected float getScanShare(org.apache.hadoop.conf.Configuration conf)

Overrides:

getScanShare in class RWQueueRpcExecutor

dispatch

public boolean dispatch(CallRunner callTask)

Description copied from class: RpcExecutor

Add the request to the executor queue

Overrides:

dispatch in class RWQueueRpcExecutor

getCallQueueHandlerFactor

protected float getCallQueueHandlerFactor(org.apache.hadoop.conf.Configuration conf)

Overrides:

getCallQueueHandlerFactor in class RpcExecutor