Package | Description |
---|---|
org.apache.flink.streaming.api.datastream |
Modifier and Type | Method and Description |
---|---|
void |
DataStream.collectAsync(DataStream.Collector<T> collector)
Sets up the collection of the elements in this
DataStream , which can be retrieved
later via the given DataStream.Collector . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.