Class PluggableBlockingQueue

All Implemented Interfaces:
Iterable<org.apache.hadoop.hbase.ipc.CallRunner>, Collection<org.apache.hadoop.hbase.ipc.CallRunner>, BlockingQueue<org.apache.hadoop.hbase.ipc.CallRunner>, Queue<org.apache.hadoop.hbase.ipc.CallRunner>

@Public @Evolving public abstract class PluggableBlockingQueue extends Object implements BlockingQueue<org.apache.hadoop.hbase.ipc.CallRunner>
Abstract class template for defining a pluggable blocking queue implementation to be used by the 'pluggable' call queue type in the RpcExecutor. The intention is that the constructor shape helps re-inforce the expected parameters needed to match up to how the RpcExecutor will instantiate instances of the queue. If the implementation class implements the ConfigurationObserver interface, it will also be wired into configuration changes. Instantiation requires a constructor with final int maxQueueLength, final PriorityFunction priority, final Configuration conf) as the arguments.
  • Field Details

    • maxQueueLength

      protected final int maxQueueLength
    • priority

      protected final org.apache.hadoop.hbase.ipc.PriorityFunction priority
    • conf

      protected final org.apache.hadoop.conf.Configuration conf
  • Constructor Details

    • PluggableBlockingQueue

      public PluggableBlockingQueue(int maxQueueLength, org.apache.hadoop.hbase.ipc.PriorityFunction priority, org.apache.hadoop.conf.Configuration conf)