Interface | Description |
---|---|
AsyncCollector<OUT> |
The async collector collects data/errors from the user code while processing
asynchronous I/O operations.
|
AsyncFunction<IN,OUT> |
A function to trigger async I/O operations.
|
Class | Description |
---|---|
JavaAsyncCollectorWrapper<OUT> |
Internal wrapper class to map a Flink's Java API
JavaAsyncCollector to a Scala
AsyncCollector . |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.