| 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.
|
| 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() |
| Modifier and Type | Method and Description |
|---|---|
DequeueResult<byte[]> |
AbstractQueueConsumer.dequeue() |
DequeueResult<byte[]> |
AbstractQueueConsumer.dequeue(int maxBatchSize) |
| Modifier and Type | Method and Description |
|---|---|
DequeueResult |
InMemoryQueueConsumer.dequeue() |
DequeueResult |
InMemoryQueueConsumer.dequeue(int maxBatchSize) |
| 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) |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.