co.cask.cdap.data2.transaction.queue.inmemory

Class InMemoryQueue

java.lang.Object

co.cask.cdap.data2.transaction.queue.inmemory.InMemoryQueue

public class InMemoryQueue
extends Object

Implementation of an in-memory queue.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	InMemoryQueue.ConsumerState The state of a single consumer, gets modified.
static class	InMemoryQueue.Key Used as the key of each queue item, composed of a transaction id and a sequence number within the transaction.

Constructor Summary

Constructors

Constructor and Description
InMemoryQueue()

Method Summary

Methods

Modifier and Type	Method and Description
void	ack(List<InMemoryQueue.Key> dequeuedKeys, ConsumerConfig config)
void	clear()
ImmutablePair<List<InMemoryQueue.Key>,List<byte[]>>	dequeue(co.cask.tephra.Transaction tx, ConsumerConfig config, InMemoryQueue.ConsumerState consumerState, int maxBatchSize)
void	enqueue(long txId, int seqId, QueueEntry entry)
void	evict(List<InMemoryQueue.Key> dequeuedKeys, int numGroups)
int	getSize()
void	undoDequeue(List<InMemoryQueue.Key> dequeuedKeys, ConsumerConfig config)
void	undoEnqueue(long txId, int seqId)

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryQueue

public InMemoryQueue()

Method Detail

clear

public void clear()

getSize

public int getSize()

enqueue

public void enqueue(long txId,
           int seqId,
           QueueEntry entry)

undoEnqueue

public void undoEnqueue(long txId,
               int seqId)

dequeue

public ImmutablePair<List<InMemoryQueue.Key>,List<byte[]>> dequeue(co.cask.tephra.Transaction tx,
                                                          ConsumerConfig config,
                                                          InMemoryQueue.ConsumerState consumerState,
                                                          int maxBatchSize)

ack

public void ack(List<InMemoryQueue.Key> dequeuedKeys,
       ConsumerConfig config)

undoDequeue

public void undoDequeue(List<InMemoryQueue.Key> dequeuedKeys,
               ConsumerConfig config)

evict

public void evict(List<InMemoryQueue.Key> dequeuedKeys,
         int numGroups)