Package org.apache.hadoop.hbase.client

Class TestAsyncClientPauseForServerOverloaded.OverloadedRpcScheduler

java.lang.Object
org.apache.hadoop.hbase.ipc.RpcScheduler
org.apache.hadoop.hbase.ipc.SimpleRpcScheduler
org.apache.hadoop.hbase.client.TestAsyncClientPauseForServerOverloaded.OverloadedRpcScheduler
All Implemented Interfaces:
org.apache.hadoop.hbase.conf.ConfigurationObserver
Enclosing class:
TestAsyncClientPauseForServerOverloaded
public static final class TestAsyncClientPauseForServerOverloaded.OverloadedRpcScheduler extends org.apache.hadoop.hbase.ipc.SimpleRpcScheduler

  • Nested Class Summary

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

    org.apache.hadoop.hbase.ipc.RpcScheduler.Context

  • Field Summary

    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
    OverloadedRpcScheduler(org.apache.hadoop.conf.Configuration conf, int handlerCount, int priorityHandlerCount, int replicationHandlerCount, int metaTransitionHandler, org.apache.hadoop.hbase.ipc.PriorityFunction priority, org.apache.hadoop.hbase.Abortable server, int highPriorityLevel)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    dispatch(org.apache.hadoop.hbase.ipc.CallRunner callTask)
     

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

    getActiveBulkLoadRpcHandlerCount, getActiveGeneralRpcHandlerCount, getActiveMetaPriorityRpcHandlerCount, getActivePriorityRpcHandlerCount, getActiveReadRpcHandlerCount, getActiveReplicationRpcHandlerCount, getActiveRpcHandlerCount, getActiveScanRpcHandlerCount, getActiveWriteRpcHandlerCount, getBulkLoadQueueLength, getCallQueueInfo, getGeneralQueueLength, getMetaPriorityQueueLength, getNumGeneralCallsDropped, getNumLifoModeSwitches, getPriorityQueueLength, getReadQueueLength, getReplicationQueueLength, getScanQueueLength, getWriteQueueLength, init, onConfigurationChange, start, stop

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • OverloadedRpcScheduler

      public OverloadedRpcScheduler(org.apache.hadoop.conf.Configuration conf, int handlerCount, int priorityHandlerCount, int replicationHandlerCount, int metaTransitionHandler, org.apache.hadoop.hbase.ipc.PriorityFunction priority, org.apache.hadoop.hbase.Abortable server, int highPriorityLevel)

  • Method Details

    • dispatch

      public boolean dispatch(org.apache.hadoop.hbase.ipc.CallRunner callTask)
      Overrides:
      dispatch in class org.apache.hadoop.hbase.ipc.SimpleRpcScheduler