Package | Description |
---|---|
org.apache.flink.streaming.api.operators.async | |
org.apache.flink.streaming.api.operators.async.queue |
Class and Description |
---|
StreamElementQueue
Interface for blocking stream element queues for the
AsyncWaitOperator . |
Class and Description |
---|
AsyncCollectionResult
AsyncResult sub class for asynchronous result collections. |
AsyncResult
Asynchronous result returned by the
StreamElementQueue . |
AsyncWatermarkResult
AsyncResult subclass for asynchronous result Watermark . |
StreamElementQueue
Interface for blocking stream element queues for the
AsyncWaitOperator . |
StreamElementQueueEntry
Entry class for the
StreamElementQueue . |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.