Re: Rich variant for Async IO in Scala

Posted by Bruno Aranda on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Rich-variant-for-Async-IO-in-Scala-tp24388p24497.html

Hi,

Tried again last night. The problem is that I was trying to use org.apache.flink.streaming.api.scala.AsyncDataStream, and that won't compile against the RichAsyncFunction. I could change it to use  org.apache.flink.streaming.api.datastream.AsyncDataStream instead, but it is not as elegant as it requires the result to be a Java collection. But it works.

Thanks!

Bruno

On Mon, 12 Nov 2018 at 16:43 Timo Walther <[hidden email]> wrote:

Hi Bruno,

`org.apache.flink.streaming.api.functions.async.RichAsyncFunction`
should also work for the Scala API. `RichMapFunction` or
`RichFilterFunction` are also shared between both APIs.

Is there anything that blocks you from using it?

Regards,
Timo

Am 09.11.18 um 01:38 schrieb Bruno Aranda:
> Hi,
>
> I see that the AsyncFunction for Scala does not seem to have a rich
> variant like the Java one. Is there a particular reason for this? Is
> there any workaround?
>
> Thanks!
>
> Bruno