It should compile against a RichAsyncFunction as well. Can you open an
issue on JIRA for this? Including the compiler issues that you observe.
Thank you.
Am 13.11.18 um 15:40 schrieb Bruno Aranda:
Hi,
Tried again last night. The problem is that I was trying to
use
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
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
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
