Package | Description |
---|---|
org.apache.flink.streaming.api.operators.async.queue |
Modifier and Type | Interface and Description |
---|---|
interface |
AsyncCollectionResult<T>
AsyncResult sub class for asynchronous result collections. |
interface |
AsyncWatermarkResult
AsyncResult subclass for asynchronous result Watermark . |
Modifier and Type | Class and Description |
---|---|
class |
StreamElementQueueEntry<T>
Entry class for the
StreamElementQueue . |
class |
StreamRecordQueueEntry<OUT>
StreamElementQueueEntry implementation for StreamRecord . |
class |
WatermarkQueueEntry
StreamElementQueueEntry implementation for the Watermark . |
Modifier and Type | Method and Description |
---|---|
AsyncResult |
UnorderedStreamElementQueue.peekBlockingly() |
AsyncResult |
StreamElementQueue.peekBlockingly()
Peek at the head of the queue and return the first completed
AsyncResult . |
AsyncResult |
OrderedStreamElementQueue.peekBlockingly() |
AsyncResult |
UnorderedStreamElementQueue.poll() |
AsyncResult |
StreamElementQueue.poll()
Poll the first completed
AsyncResult from the head of this queue. |
AsyncResult |
OrderedStreamElementQueue.poll() |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.