org.apache.accumulo.server.tabletserver
Class CompactionQueue
java.lang.Object
java.util.AbstractCollection<E>
java.util.AbstractQueue<Runnable>
org.apache.accumulo.server.tabletserver.CompactionQueue
- All Implemented Interfaces:
- Iterable<Runnable>, Collection<Runnable>, BlockingQueue<Runnable>, Queue<Runnable>
public class CompactionQueue
- extends AbstractQueue<Runnable>
- implements BlockingQueue<Runnable>
CompactionQueue
public CompactionQueue()
poll
public Runnable poll()
- Specified by:
poll
in interface Queue<Runnable>
peek
public Runnable peek()
- Specified by:
peek
in interface Queue<Runnable>
offer
public boolean offer(Runnable e)
- Specified by:
offer
in interface BlockingQueue<Runnable>
- Specified by:
offer
in interface Queue<Runnable>
put
public void put(Runnable e)
throws InterruptedException
- Specified by:
put
in interface BlockingQueue<Runnable>
- Throws:
InterruptedException
offer
public boolean offer(Runnable e,
long timeout,
TimeUnit unit)
throws InterruptedException
- Specified by:
offer
in interface BlockingQueue<Runnable>
- Throws:
InterruptedException
take
public Runnable take()
throws InterruptedException
- Specified by:
take
in interface BlockingQueue<Runnable>
- Throws:
InterruptedException
poll
public Runnable poll(long timeout,
TimeUnit unit)
throws InterruptedException
- Specified by:
poll
in interface BlockingQueue<Runnable>
- Throws:
InterruptedException
remainingCapacity
public int remainingCapacity()
- Specified by:
remainingCapacity
in interface BlockingQueue<Runnable>
drainTo
public int drainTo(Collection<? super Runnable> c)
- Specified by:
drainTo
in interface BlockingQueue<Runnable>
drainTo
public int drainTo(Collection<? super Runnable> c,
int maxElements)
- Specified by:
drainTo
in interface BlockingQueue<Runnable>
iterator
public Iterator<Runnable> iterator()
- Specified by:
iterator
in interface Iterable<Runnable>
- Specified by:
iterator
in interface Collection<Runnable>
- Specified by:
iterator
in class AbstractCollection<Runnable>
size
public int size()
- Specified by:
size
in interface Collection<Runnable>
- Specified by:
size
in class AbstractCollection<Runnable>
Copyright © 2012 The Apache Software Foundation. All Rights Reserved.