Re: RichAsyncFunction in Scala

is no way of using the RichAsyncFunction in Scala, this means I can't get access to the RuntimeContext. I know someone is working on this: https://issues.apache.org/jira/browse/FLINK-6756 , however in the meantime is there a workaround for this? I'm particularly interested in getting

RichAsyncFunction in Scala

Hi, Currently there is no way of using the RichAsyncFunction in Scala, this means I can't get access to the RuntimeContext. I know someone is working on this: https://issues.apache.org/jira/browse/FLINK-6756 , however in the meantime is there a workaround for this? I'm particularly int

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

RichAsyncFunction in scala

Hi, It lacks a version of RichAsyncFunction class in the scala API or the possibility to handle a class which extends AbstractRichFunction and implements AsyncFunction (from the scala API). I made a small dev on our current flink fork because we need to use the open method to add our custom metri