flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: RichAsyncFunction for Scala?
Date Thu, 16 May 2019 07:25:31 GMT
Hi Shannon,

That's a good observation. To be honest, I know why the Scala AsyncFunction
does not implement RichFunction.
Maybe this was not intentional and just overlooked when porting the
functionality to Scala.

Would you mind creating a Jira ticket for this?

Thank you,

Am Di., 14. Mai 2019 um 23:29 Uhr schrieb Shannon Carey <scarey@expedia.com

> I have some awkward code in a few Flink jobs which is converting a Scala
> stream into a Java stream in order to pass it to
> AsyncDataStream.unorderedWait(), and using a Java RichAsyncFunction, due to
> old versions of Flink not having the ability to do async stuff with a Scala
> stream.
> In newer versions of Flink, I see that
> org.apache.flink.streaming.api.scala.AsyncDataStream is available. However,
> it accepts only org.apache.flink.streaming.api.scala.async.AsyncFunction,
> and there does not appear to be an AbstractRichFunction subclass of that
> trait as I expected. Is there a way to use the Scala interfaces but provide
> a rich AsyncFunction to AsyncDataStream.unorderedWait()? If not, I will
> leave the old code as-is.
> Thanks,
> Shannon

View raw message