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

Packages that use InMemoryQueue.ConsumerState

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

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

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

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)