Uses of Class
org.apache.hadoop.hbase.ipc.CallRunner

Packages that use org.apache.hadoop.hbase.ipc.CallRunner
Package
Description
org.apache.hadoop.hbase.ipc
Tools to help define network clients and servers.

  • Uses of org.apache.hadoop.hbase.ipc.CallRunner in org.apache.hadoop.hbase.ipc

    Fields in org.apache.hadoop.hbase.ipc with type parameters of type org.apache.hadoop.hbase.ipc.CallRunner in in
    Modifier and Type
    Field
    Description
    protected final List<BlockingQueue<org.apache.hadoop.hbase.ipc.CallRunner>>
    RpcExecutor.queues
     
    Methods in org.apache.hadoop.hbase.ipc that return org.apache.hadoop.hbase.ipc.CallRunner in in
    Modifier and Type
    Method
    Description
    org.apache.hadoop.hbase.ipc.CallRunner
    AdaptiveLifoCoDelCallQueue.element()
     
    protected org.apache.hadoop.hbase.ipc.CallRunner
    FastPathRpcHandler.getCallRunner()
     
    protected org.apache.hadoop.hbase.ipc.CallRunner
    RpcHandler.getCallRunner()
    Returns A CallRunner n
    org.apache.hadoop.hbase.ipc.CallRunner
    AdaptiveLifoCoDelCallQueue.peek()
     
    org.apache.hadoop.hbase.ipc.CallRunner
    AdaptiveLifoCoDelCallQueue.poll()
     
    org.apache.hadoop.hbase.ipc.CallRunner
    AdaptiveLifoCoDelCallQueue.poll(long timeout, TimeUnit unit)
     
    org.apache.hadoop.hbase.ipc.CallRunner
    AdaptiveLifoCoDelCallQueue.remove()
     
    org.apache.hadoop.hbase.ipc.CallRunner
    AdaptiveLifoCoDelCallQueue.take()
    Behaves as LinkedBlockingQueue.take(), except it will silently skip all calls which it thinks should be dropped.
    Methods in org.apache.hadoop.hbase.ipc that return types with arguments of type org.apache.hadoop.hbase.ipc.CallRunner in in
    Modifier and Type
    Method
    Description
    protected List<BlockingQueue<org.apache.hadoop.hbase.ipc.CallRunner>>
    RpcExecutor.getQueues()
    Returns the list of request queues
    Iterator<org.apache.hadoop.hbase.ipc.CallRunner>
    AdaptiveLifoCoDelCallQueue.iterator()
     
    Methods in org.apache.hadoop.hbase.ipc with parameters of type org.apache.hadoop.hbase.ipc.CallRunner in in
    Modifier and Type
    Method
    Description
    boolean
    AdaptiveLifoCoDelCallQueue.add(org.apache.hadoop.hbase.ipc.CallRunner callRunner)
     
    boolean
    BalancedQueueRpcExecutor.dispatch(org.apache.hadoop.hbase.ipc.CallRunner callTask)
     
    boolean
    DelegatingRpcScheduler.dispatch(org.apache.hadoop.hbase.ipc.CallRunner task)
     
    boolean
    FastPathBalancedQueueRpcExecutor.dispatch(org.apache.hadoop.hbase.ipc.CallRunner callTask)
     
    boolean
    FastPathRWQueueRpcExecutor.dispatch(org.apache.hadoop.hbase.ipc.CallRunner callTask)
     
    boolean
    FifoRpcScheduler.dispatch(org.apache.hadoop.hbase.ipc.CallRunner task)
     
    boolean
    MasterFifoRpcScheduler.dispatch(org.apache.hadoop.hbase.ipc.CallRunner task)
     
    abstract boolean
    RpcExecutor.dispatch(org.apache.hadoop.hbase.ipc.CallRunner callTask)
    Add the request to the executor queue
    abstract boolean
    RpcScheduler.dispatch(org.apache.hadoop.hbase.ipc.CallRunner task)
    Dispatches an RPC request asynchronously.
    boolean
    RWQueueRpcExecutor.dispatch(org.apache.hadoop.hbase.ipc.CallRunner callTask)
     
    boolean
    SimpleRpcScheduler.dispatch(org.apache.hadoop.hbase.ipc.CallRunner callTask)
     
    protected boolean
    RWQueueRpcExecutor.dispatchTo(boolean toWriteQueue, boolean toScanQueue, org.apache.hadoop.hbase.ipc.CallRunner callTask)
     
    protected boolean
    FifoRpcScheduler.executeRpcCall(ThreadPoolExecutor executor, AtomicInteger queueSize, org.apache.hadoop.hbase.ipc.CallRunner task)
     
    protected String
    FifoRpcScheduler.getCallMethod(org.apache.hadoop.hbase.ipc.CallRunner task)
     
    int
    QueueBalancer.getNextQueue(org.apache.hadoop.hbase.ipc.CallRunner callRunner)
    Returns the index of the next queue to which a request should be inserted
    int
    RandomQueueBalancer.getNextQueue(org.apache.hadoop.hbase.ipc.CallRunner callRunner)
     
    boolean
    AdaptiveLifoCoDelCallQueue.offer(org.apache.hadoop.hbase.ipc.CallRunner callRunner)
     
    boolean
    AdaptiveLifoCoDelCallQueue.offer(org.apache.hadoop.hbase.ipc.CallRunner callRunner, long timeout, TimeUnit unit)
     
    void
    AdaptiveLifoCoDelCallQueue.put(org.apache.hadoop.hbase.ipc.CallRunner callRunner)
     
    protected boolean
    RWQueueRpcExecutor.shouldDispatchToScanQueue(org.apache.hadoop.hbase.ipc.CallRunner task)
     
    Method parameters in org.apache.hadoop.hbase.ipc with type arguments of type org.apache.hadoop.hbase.ipc.CallRunner in in
    Modifier and Type
    Method
    Description
    boolean
    AdaptiveLifoCoDelCallQueue.addAll(Collection<? extends org.apache.hadoop.hbase.ipc.CallRunner> c)
     
    int
    AdaptiveLifoCoDelCallQueue.drainTo(Collection<? super org.apache.hadoop.hbase.ipc.CallRunner> c)
     
    int
    AdaptiveLifoCoDelCallQueue.drainTo(Collection<? super org.apache.hadoop.hbase.ipc.CallRunner> c, int maxElements)
     
    static org.apache.hadoop.hbase.ipc.QueueBalancer
    RpcExecutor.getBalancer(String executorName, org.apache.hadoop.conf.Configuration conf, List<BlockingQueue<org.apache.hadoop.hbase.ipc.CallRunner>> queues)
     
    protected org.apache.hadoop.hbase.ipc.RpcHandler
    FastPathBalancedQueueRpcExecutor.getHandler(String name, double handlerFailureThreshhold, int handlerCount, BlockingQueue<org.apache.hadoop.hbase.ipc.CallRunner> q, AtomicInteger activeHandlerCount, AtomicInteger failedHandlerCount, org.apache.hadoop.hbase.Abortable abortable)
     
    protected org.apache.hadoop.hbase.ipc.RpcHandler
    FastPathRWQueueRpcExecutor.getHandler(String name, double handlerFailureThreshhold, int handlerCount, BlockingQueue<org.apache.hadoop.hbase.ipc.CallRunner> q, AtomicInteger activeHandlerCount, AtomicInteger failedHandlerCount, org.apache.hadoop.hbase.Abortable abortable)
     
    protected org.apache.hadoop.hbase.ipc.RpcHandler
    RpcExecutor.getHandler(String name, double handlerFailureThreshhold, int handlerCount, BlockingQueue<org.apache.hadoop.hbase.ipc.CallRunner> q, AtomicInteger activeHandlerCount, AtomicInteger failedHandlerCount, org.apache.hadoop.hbase.Abortable abortable)
    Override if providing alternate Handler implementation.
    protected void
    RpcExecutor.startHandlers(String nameSuffix, int numHandlers, List<BlockingQueue<org.apache.hadoop.hbase.ipc.CallRunner>> callQueues, int qindex, int qsize, int port, AtomicInteger activeHandlerCount)
    Start up our handlers.
    Constructor parameters in org.apache.hadoop.hbase.ipc with type arguments of type org.apache.hadoop.hbase.ipc.CallRunner in in
    Modifier
    Constructor
    Description
     
    RandomQueueBalancer(org.apache.hadoop.conf.Configuration conf, String executorName, List<BlockingQueue<org.apache.hadoop.hbase.ipc.CallRunner>> queues)