Re: RichAsyncFunction in Scala

Hi Wouter, you could use the Java classes as a workaround. If you take a look at the implementation [1], you will see that Scala only wraps the Java classes. I think you can implement the same. You can convert your result stream back into a Scala stream by calling `new o.a.f.streaming.api.sca

Re: RichAsyncFunction in scala

Hi, There is this Jira issue: https://issues.apache.org/jira/browse/FLINK-6756 Best, Aljoscha > On 28. Dec 2017, at 17:10, Antoine Philippot > wrote: > > Hi Ufuk, > > I don't think it is possible as I use this function as a parameter of >

Re: RichAsyncFunction in scala

Hi Ufuk, I don't think it is possible as I use this function as a parameter of AsyncDataStream (from the scala API) which is mandatory to use with the scala DataStream. Le jeu. 28 déc. 2017 à 16:55, Ufuk Celebi a écrit : > Hey Antoine, > > isn't it possible to use the Java RichAsyncFunction f

Re: RichAsyncFunction in scala

Hey Antoine, isn't it possible to use the Java RichAsyncFunction from Scala like this: class Test extends RichAsyncFunction[Int, Int] { override def open(parameters: Configuration): Unit = super.open(parameters) override def asyncInvoke(input: Int, resultFuture: functions.async.ResultFuture