Hi,

Collecting results locally (e.g., for unit testing) is possible in the
DataSet API by using "LocalCollectionOutputFormat", as described in
the programming guide:
https://ci.apache.org/projects/flink/flink-docs-release-0.10/apis/programming_guide.html#collection-data-sources-and-sinks

Can something similar be done for the DataStream API?

Thanks,

Filipe

Reply via email to