Try the getJavaStream method of the scala DataStream.

Best,
Gábor




2016-01-05 19:14 GMT+01:00 Filipe Correia <filipe.corr...@nmusic.pt>:
> 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

Reply via email to