org.apache.hadoop.hbase.ipc

Class MasterFifoRpcScheduler

java.lang.Object

org.apache.hadoop.hbase.ipc.RpcScheduler

org.apache.hadoop.hbase.ipc.FifoRpcScheduler

org.apache.hadoop.hbase.ipc.MasterFifoRpcScheduler

@InterfaceAudience.Private
 @InterfaceStability.Evolving
public class MasterFifoRpcScheduler
extends FifoRpcScheduler

A special RpcScheduler} only used for master. This scheduler separates RegionServerReport requests to independent handlers to avoid these requests block other requests. To use this scheduler, please set "hbase.master.rpc.scheduler.factory.class" to "org.apache.hadoop.hbase.ipc.MasterFifoRpcScheduler".

Nested Class Summary

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

RpcScheduler.Context

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG
static String	MASTER_SERVER_REPORT_HANDLER_COUNT Set RSReport requests handlers count when masters use MasterFifoRpcScheduler.
private static String	REGION_SERVER_REPORT
private ThreadPoolExecutor	rsReportExecutor
private int	rsReportHandlerCount
private AtomicInteger	rsReportQueueSize
private int	rsRsreportMaxQueueLength

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

executor, handlerCount, maxQueueLength, queueSize

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

IPC_SERVER_MAX_CALLQUEUE_LENGTH, IPC_SERVER_PRIORITY_MAX_CALLQUEUE_LENGTH

Constructor Summary

Constructors

Constructor and Description
MasterFifoRpcScheduler(org.apache.hadoop.conf.Configuration conf, int callHandlerCount, int rsReportHandlerCount)

Method Summary

Modifier and Type	Method and Description
boolean	dispatch(CallRunner task) Dispatches an RPC request asynchronously.
int	getActiveRpcHandlerCount() Retrieves the total number of active handler.
CallQueueInfo	getCallQueueInfo() Get call queue information
int	getGeneralQueueLength() Retrieves length of the general queue for metrics.
void	start() Prepares for request serving.
void	stop() Stops serving new requests.

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

executeRpcCall, getActiveGeneralRpcHandlerCount, getActiveMetaPriorityRpcHandlerCount, getActivePriorityRpcHandlerCount, getActiveReadRpcHandlerCount, getActiveReplicationRpcHandlerCount, getActiveScanRpcHandlerCount, getActiveWriteRpcHandlerCount, getCallMethod, getMetaPriorityQueueLength, getNumGeneralCallsDropped, getNumLifoModeSwitches, getPriorityQueueLength, getReadQueueLength, getReplicationQueueLength, getScanQueueLength, getWriteQueueLength, init, updateMethodCountAndSizeByQueue

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.slf4j.Logger LOG

MASTER_SERVER_REPORT_HANDLER_COUNT

public static final String MASTER_SERVER_REPORT_HANDLER_COUNT

Set RSReport requests handlers count when masters use MasterFifoRpcScheduler. The default value is half of "hbase.regionserver.handler.count" value, but at least 1. The other handlers count is "hbase.regionserver.handler.count" value minus RSReport handlers count, but at least 1 too.

See Also:

Constant Field Values

REGION_SERVER_REPORT

private static final String REGION_SERVER_REPORT

See Also:

Constant Field Values

rsReportHandlerCount

private final int rsReportHandlerCount

rsRsreportMaxQueueLength

private final int rsRsreportMaxQueueLength

rsReportQueueSize

private final AtomicInteger rsReportQueueSize

rsReportExecutor

private ThreadPoolExecutor rsReportExecutor

Constructor Detail

MasterFifoRpcScheduler

public MasterFifoRpcScheduler(org.apache.hadoop.conf.Configuration conf,
                              int callHandlerCount,
                              int rsReportHandlerCount)

Method Detail

start

public void start()

Description copied from class: RpcScheduler

Prepares for request serving. An implementation may start some handler threads here.

Overrides:

start in class FifoRpcScheduler

stop

public void stop()

Description copied from class: RpcScheduler

Stops serving new requests.

Overrides:

stop in class FifoRpcScheduler

dispatch

public boolean dispatch(CallRunner task)
                 throws IOException,
                        InterruptedException

Description copied from class: RpcScheduler

Dispatches an RPC request asynchronously. An implementation is free to choose to process the request immediately or delay it for later processing.

Overrides:

dispatch in class FifoRpcScheduler

Parameters:

task - the request to be dispatched

Throws:

IOException

InterruptedException

getGeneralQueueLength

public int getGeneralQueueLength()

Description copied from class: RpcScheduler

Retrieves length of the general queue for metrics.

Overrides:

getGeneralQueueLength in class FifoRpcScheduler

getActiveRpcHandlerCount

public int getActiveRpcHandlerCount()

Description copied from class: RpcScheduler

Retrieves the total number of active handler.

Overrides:

getActiveRpcHandlerCount in class FifoRpcScheduler

getCallQueueInfo

public CallQueueInfo getCallQueueInfo()

Description copied from class: RpcScheduler

Get call queue information

Overrides:

getCallQueueInfo in class FifoRpcScheduler