Hi Filipe, You can take a look at `DataStreamUtils.collect` in flink-contrib/flink-streaming-contrib.
Best, Gábor 2016-01-05 16:14 GMT+01:00 Filipe Correia <filipe.corr...@nmusic.pt>: > 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