Uses of Class
co.cask.cdap.data2.transaction.queue.inmemory.InMemoryQueue.Key

Packages that use InMemoryQueue.Key

Package	Description
co.cask.cdap.data2.transaction.queue.inmemory	This package contains in memory implementation of queues.

Uses of InMemoryQueue.Key in co.cask.cdap.data2.transaction.queue.inmemory

Methods in co.cask.cdap.data2.transaction.queue.inmemory that return types with arguments of type InMemoryQueue.Key

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

Methods in co.cask.cdap.data2.transaction.queue.inmemory with parameters of type InMemoryQueue.Key

Modifier and Type	Method and Description
int	InMemoryQueue.Key.compareTo(InMemoryQueue.Key o)

Method parameters in co.cask.cdap.data2.transaction.queue.inmemory with type arguments of type InMemoryQueue.Key

Modifier and Type	Method and Description
void	InMemoryQueue.ack(List<InMemoryQueue.Key> dequeuedKeys, ConsumerConfig config)
void	InMemoryQueue.evict(List<InMemoryQueue.Key> dequeuedKeys, int numGroups)
void	InMemoryQueue.undoDequeue(List<InMemoryQueue.Key> dequeuedKeys, ConsumerConfig config)