Package 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

@Private
@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	Description
private static final org.slf4j.Logger	LOG
static final String	MASTER_SERVER_REPORT_HANDLER_COUNT	Set RSReport requests handlers count when masters use MasterFifoRpcScheduler.
private static final String	REGION_SERVER_REPORT
private ThreadPoolExecutor	rsReportExecutor
private final int	rsReportHandlerCount
private final AtomicInteger	rsReportQueueSize
private final 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_BULKLOAD_MAX_CALLQUEUE_LENGTH, IPC_SERVER_MAX_CALLQUEUE_LENGTH, IPC_SERVER_PRIORITY_MAX_CALLQUEUE_LENGTH, IPC_SERVER_REPLICATION_MAX_CALLQUEUE_LENGTH

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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, getActiveBulkLoadRpcHandlerCount, getActiveGeneralRpcHandlerCount, getActiveMetaPriorityRpcHandlerCount, getActivePriorityRpcHandlerCount, getActiveReadRpcHandlerCount, getActiveReplicationRpcHandlerCount, getActiveScanRpcHandlerCount, getActiveWriteRpcHandlerCount, getBulkLoadQueueLength, 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 Details

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 Details

MasterFifoRpcScheduler

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

Method Details

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)

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

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