flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Márton Balassi <balassi.mar...@gmail.com>
Subject Re: DataStreamUtils and Scala
Date Mon, 01 Feb 2016 17:53:05 GMT
Hey Cory,

Sorry, I did not mean to break your code. One solution that I could suggest
is to do it the way we have it for the batch api, namely having a scala
version for DataStreamUtils too. It might be placed under flink-contrib for
the time being.

Would that solution fit your needs?

On Mon, Feb 1, 2016 at 6:40 PM, Cory Monty <cory.monty@getbraintree.com>

> Hey there,
> We were using DataStreamUtils.collect in Scala for automated testing,
> which only works because of `DataStream.getJavaStream` accessor in the
> Scala version of `DataStream`. However, a recent commit (
> https://github.com/apache/flink/commit/086acf681f01f2da530c04289e0682c56f98a378)
> removed `getJavaStream` and replaced the method with a private version that
> we can no longer access from our tests.
> Do you have an alternative version of DataStreamUtils that does not
> require a Java DataStream?
> Cheers,
> Cory

View raw message