Hi Gábor, Thanks! I'm using Scala though. DataStreamUtils.collect() depends on org.apache.flink.streaming.api.datastream.DataStream, rather than org.apache.flink.streaming.api.scala.DataStream. Any suggestion on how to handle this, other than creating my own scala implementation of DataStreamUtils.collect()?
Thanks, Filipe On Tue, Jan 5, 2016 at 3:33 PM, Gábor Gévay <gga...@gmail.com> wrote: > 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
