public final class Row.Queue
extends java.lang.Object
private final java.util.concurrent.ArrayBlockingQueue<Row.Entry> queue
public void put(Row.Entry e) throws java.lang.InterruptedException
java.lang.InterruptedException
public Row.Entry take() throws java.lang.InterruptedException
java.lang.InterruptedException
public Row.Entry get(byte[] key)
public Row.Entry delete(byte[] key)