Perfect, thanks!
Filipe
On Tue, Jan 5, 2016 at 6:23 PM, Gábor Gévay wrote:
> Try the getJavaStream method of the scala DataStream.
>
> Best,
> Gábor
>
>
>
>
> 2016-01-05 19:14 GMT+01:00 Filipe Correia :
>> Hi Gábor, Thanks!
>>
>> I'm using Scala though. DataStreamUtils.collect() depends on
>> or
Try the getJavaStream method of the scala DataStream.
Best,
Gábor
2016-01-05 19:14 GMT+01:00 Filipe Correia :
> 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.ap
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
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 :
> Hi,
>
> Collecting results locally (e.g., for unit testing) is possible in the
> DataSet API by using "LocalCollectionOutputFormat", a
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 some
