Uses of Interface
co.cask.cdap.data2.queue.DequeueResult

Packages that use DequeueResult

Package	Description
co.cask.cdap.data2.queue	API definition for queue for the txds2 system.
co.cask.cdap.data2.transaction.queue	Transaction aware queue implementation.
co.cask.cdap.data2.transaction.queue.inmemory	This package contains in memory implementation of queues.
co.cask.cdap.data2.transaction.stream	This package contains transaction stream consumer classes for maintaining stateful consumption of stream entries.

Uses of DequeueResult in co.cask.cdap.data2.queue

Methods in co.cask.cdap.data2.queue that return DequeueResult

Modifier and Type	Method and Description
DequeueResult<byte[]>	QueueConsumer.dequeue() Dequeue an entry from the queue.
DequeueResult<byte[]>	ForwardingQueueConsumer.dequeue()
DequeueResult<byte[]>	QueueConsumer.dequeue(int maxBatchSize) Dequeue multiple entries from the queue.
DequeueResult<byte[]>	ForwardingQueueConsumer.dequeue(int maxBatchSize)
static <T> DequeueResult<T>	DequeueResult.Empty.result()

Uses of DequeueResult in co.cask.cdap.data2.transaction.queue

Methods in co.cask.cdap.data2.transaction.queue that return DequeueResult

Modifier and Type	Method and Description
DequeueResult<byte[]>	AbstractQueueConsumer.dequeue()
DequeueResult<byte[]>	AbstractQueueConsumer.dequeue(int maxBatchSize)

Uses of DequeueResult in co.cask.cdap.data2.transaction.queue.inmemory

Methods in co.cask.cdap.data2.transaction.queue.inmemory that return DequeueResult

Modifier and Type	Method and Description
DequeueResult	InMemoryQueueConsumer.dequeue()
DequeueResult	InMemoryQueueConsumer.dequeue(int maxBatchSize)

Uses of DequeueResult in co.cask.cdap.data2.transaction.stream

Methods in co.cask.cdap.data2.transaction.stream that return DequeueResult

Modifier and Type	Method and Description
DequeueResult<co.cask.cdap.api.flow.flowlet.StreamEvent>	StreamConsumer.poll(int maxEvents, long timeout, TimeUnit timeoutUnit) Retrieves up to maxEvents of StreamEvent from the stream.
DequeueResult<co.cask.cdap.api.flow.flowlet.StreamEvent>	ForwardingStreamConsumer.poll(int maxEvents, long timeout, TimeUnit timeoutUnit)
DequeueResult<co.cask.cdap.api.flow.flowlet.StreamEvent>	QueueToStreamConsumer.poll(int maxEvents, long timeout, TimeUnit timeoutUnit)
DequeueResult<co.cask.cdap.api.flow.flowlet.StreamEvent>	AbstractStreamFileConsumer.poll(int maxEvents, long timeout, TimeUnit timeoutUnit)