Convert Scala DataStream to Java DataStream

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Convert Scala DataStream to Java DataStream

Saiph Kappa
Hi,

I'm programming in scala and using some extra libraries made in Java. My question is:  how can I easily convert "org.apache.flink.streaming.scala.DataStream" to "org.apache.flink.streaming.api.datastream.DataStream"?

Thanks.
Reply | Threaded
Open this post in threaded view
|

Re: Convert Scala DataStream to Java DataStream

stefanobaghino
Hi Saiph,

all you have to do is to invoke the `javaStream` method on your Scala DataStream.

Hope I've been helpful. :)

On Tue, Apr 5, 2016 at 7:35 PM, Saiph Kappa <[hidden email]> wrote:
Hi,

I'm programming in scala and using some extra libraries made in Java. My question is:  how can I easily convert "org.apache.flink.streaming.scala.DataStream" to "org.apache.flink.streaming.api.datastream.DataStream"?

Thanks.



--
BR,
Stefano Baghino

Software Engineer @ Radicalbit