CallQueue (Hortonworks Data Platform Apache HBase Java API Reference)

java.lang.Object
- org.apache.hadoop.hbase.thrift.CallQueue

All Implemented Interfaces:

java.lang.Iterable<java.lang.Runnable>, java.util.Collection<java.lang.Runnable>, java.util.concurrent.BlockingQueue<java.lang.Runnable>, java.util.Queue<java.lang.Runnable>
```
public class CallQueue
extends java.lang.Object
implements java.util.concurrent.BlockingQueue<java.lang.Runnable>
```
A BlockingQueue reports waiting time in queue and queue length to ThriftMetrics.

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static class CallQueue.Call

Nested Classes
Modifier and Type	Class and Description
`static class`	`CallQueue.Call`

Constructor Summary

Constructors
Constructor and Description

CallQueue(java.util.concurrent.BlockingQueue<CallQueue.Call> underlyingQueue, ThriftMetrics metrics)

Constructors
Constructor and Description
`CallQueue(java.util.concurrent.BlockingQueue<CallQueue.Call> underlyingQueue, ThriftMetrics metrics)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`boolean`	`add(java.lang.Runnable element)`
`boolean`	`addAll(java.util.Collection<? extends java.lang.Runnable> elements)`
`void`	`clear()`
`boolean`	`contains(java.lang.Object element)`
`boolean`	`containsAll(java.util.Collection<?> elements)`
`int`	`drainTo(java.util.Collection<? super java.lang.Runnable> destination)`
`int`	`drainTo(java.util.Collection<? super java.lang.Runnable> destination, int maxElements)`
`java.lang.Runnable`	`element()`
`boolean`	`isEmpty()`
`java.util.Iterator<java.lang.Runnable>`	`iterator()`
`boolean`	`offer(java.lang.Runnable element)`
`boolean`	`offer(java.lang.Runnable element, long timeout, java.util.concurrent.TimeUnit unit)`
`java.lang.Runnable`	`peek()`
`java.lang.Runnable`	`poll()`
`java.lang.Runnable`	`poll(long timeout, java.util.concurrent.TimeUnit unit)`
`void`	`put(java.lang.Runnable element)`
`int`	`remainingCapacity()`
`java.lang.Runnable`	`remove()`
`boolean`	`remove(java.lang.Object element)`
`boolean`	`removeAll(java.util.Collection<?> elements)`
`boolean`	`retainAll(java.util.Collection<?> elements)`
`int`	`size()`
`java.lang.Runnable`	`take()`
`java.lang.Object[]`	`toArray()`
`<T> T[]`	`toArray(T[] array)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.Collection
equals, hashCode, parallelStream, removeIf, spliterator, stream

Methods inherited from interface java.lang.Iterable
forEach

- Constructor Detail
  - CallQueue
```
public CallQueue(java.util.concurrent.BlockingQueue<CallQueue.Call> underlyingQueue,
                 ThriftMetrics metrics)
```
- Method Detail
  - poll
```
public java.lang.Runnable poll()
```
    Specified by:
    
    poll in interface java.util.Queue<java.lang.Runnable>
  - poll
```
public java.lang.Runnable poll(long timeout,
                               java.util.concurrent.TimeUnit unit)
                        throws java.lang.InterruptedException
```
    Specified by:
    
    poll in interface java.util.concurrent.BlockingQueue<java.lang.Runnable>
    
    Throws:
    
    java.lang.InterruptedException
  - remove
```
public java.lang.Runnable remove()
```
    Specified by:
    
    remove in interface java.util.Queue<java.lang.Runnable>
  - take
```
public java.lang.Runnable take()
                        throws java.lang.InterruptedException
```
    Specified by:
    
    take in interface java.util.concurrent.BlockingQueue<java.lang.Runnable>
    
    Throws:
    
    java.lang.InterruptedException
  - drainTo
```
public int drainTo(java.util.Collection<? super java.lang.Runnable> destination)
```
    Specified by:
    
    drainTo in interface java.util.concurrent.BlockingQueue<java.lang.Runnable>
  - drainTo
```
public int drainTo(java.util.Collection<? super java.lang.Runnable> destination,
                   int maxElements)
```
    Specified by:
    
    drainTo in interface java.util.concurrent.BlockingQueue<java.lang.Runnable>
  - offer
```
public boolean offer(java.lang.Runnable element)
```
    Specified by:
    
    offer in interface java.util.concurrent.BlockingQueue<java.lang.Runnable>
    
    Specified by:
    
    offer in interface java.util.Queue<java.lang.Runnable>
  - offer
```
public boolean offer(java.lang.Runnable element,
                     long timeout,
                     java.util.concurrent.TimeUnit unit)
              throws java.lang.InterruptedException
```
    Specified by:
    
    offer in interface java.util.concurrent.BlockingQueue<java.lang.Runnable>
    
    Throws:
    
    java.lang.InterruptedException
  - put
```
public void put(java.lang.Runnable element)
         throws java.lang.InterruptedException
```
    Specified by:
    
    put in interface java.util.concurrent.BlockingQueue<java.lang.Runnable>
    
    Throws:
    
    java.lang.InterruptedException
  - add
```
public boolean add(java.lang.Runnable element)
```
    Specified by:
    
    add in interface java.util.Collection<java.lang.Runnable>
    
    Specified by:
    
    add in interface java.util.concurrent.BlockingQueue<java.lang.Runnable>
    
    Specified by:
    
    add in interface java.util.Queue<java.lang.Runnable>
  - addAll
```
public boolean addAll(java.util.Collection<? extends java.lang.Runnable> elements)
```
    Specified by:
    
    addAll in interface java.util.Collection<java.lang.Runnable>
  - element
```
public java.lang.Runnable element()
```
    Specified by:
    
    element in interface java.util.Queue<java.lang.Runnable>
  - peek
```
public java.lang.Runnable peek()
```
    Specified by:
    
    peek in interface java.util.Queue<java.lang.Runnable>
  - clear
```
public void clear()
```
    Specified by:
    
    clear in interface java.util.Collection<java.lang.Runnable>
  - containsAll
```
public boolean containsAll(java.util.Collection<?> elements)
```
    Specified by:
    
    containsAll in interface java.util.Collection<java.lang.Runnable>
  - isEmpty
```
public boolean isEmpty()
```
    Specified by:
    
    isEmpty in interface java.util.Collection<java.lang.Runnable>
  - iterator
```
public java.util.Iterator<java.lang.Runnable> iterator()
```
    Specified by:
    
    iterator in interface java.lang.Iterable<java.lang.Runnable>
    
    Specified by:
    
    iterator in interface java.util.Collection<java.lang.Runnable>
  - removeAll
```
public boolean removeAll(java.util.Collection<?> elements)
```
    Specified by:
    
    removeAll in interface java.util.Collection<java.lang.Runnable>
  - retainAll
```
public boolean retainAll(java.util.Collection<?> elements)
```
    Specified by:
    
    retainAll in interface java.util.Collection<java.lang.Runnable>
  - size
```
public int size()
```
    Specified by:
    
    size in interface java.util.Collection<java.lang.Runnable>
  - toArray
```
public java.lang.Object[] toArray()
```
    Specified by:
    
    toArray in interface java.util.Collection<java.lang.Runnable>
  - toArray
```
public <T> T[] toArray(T[] array)
```
    Specified by:
    
    toArray in interface java.util.Collection<java.lang.Runnable>
  - contains
```
public boolean contains(java.lang.Object element)
```
    Specified by:
    
    contains in interface java.util.Collection<java.lang.Runnable>
    
    Specified by:
    
    contains in interface java.util.concurrent.BlockingQueue<java.lang.Runnable>
  - remainingCapacity
```
public int remainingCapacity()
```
    Specified by:
    
    remainingCapacity in interface java.util.concurrent.BlockingQueue<java.lang.Runnable>
  - remove
```
public boolean remove(java.lang.Object element)
```
    Specified by:
    
    remove in interface java.util.Collection<java.lang.Runnable>
    
    Specified by:
    
    remove in interface java.util.concurrent.BlockingQueue<java.lang.Runnable>

Class CallQueue

Nested Class Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface java.util.Collection

Methods inherited from interface java.lang.Iterable

Constructor Detail

CallQueue

Method Detail

poll

poll

remove

take

drainTo

drainTo

offer

offer

put

add

addAll

element

peek

clear

containsAll

isEmpty

iterator

removeAll

retainAll

size

toArray

toArray

contains

remainingCapacity

remove