Package org.apache.hadoop.hbase.ipc

Class PluggableBlockingQueue

java.lang.Object

org.apache.hadoop.hbase.ipc.PluggableBlockingQueue

All Implemented Interfaces:

Iterable<CallRunner>, Collection<CallRunner>, BlockingQueue<CallRunner>, Queue<CallRunner>

@Public
@Evolving
public abstract class PluggableBlockingQueue
extends Object
implements BlockingQueue<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 Summary

Fields

Modifier and Type	Field	Description
protected final org.apache.hadoop.conf.Configuration	conf
protected final int	maxQueueLength
protected final PriorityFunction	priority

Constructor Summary

Constructors

Constructor	Description
PluggableBlockingQueue(int maxQueueLength, PriorityFunction priority, org.apache.hadoop.conf.Configuration conf)

Method Summary

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.BlockingQueue

add, contains, drainTo, drainTo, offer, offer, poll, put, remainingCapacity, remove, take

Methods inherited from interface java.util.Collection

addAll, clear, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface java.util.Queue

element, peek, poll, remove

Field Details

maxQueueLength

protected final int maxQueueLength

priority

protected final PriorityFunction priority

conf

protected final org.apache.hadoop.conf.Configuration conf

Constructor Details

PluggableBlockingQueue

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