RichAsyncFunction in scala
Posted by
Antoine Philippot on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/RichAsyncFunction-in-scala-tp17477.html
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 metrics from getRuntimeContext.getMetricGroup method.
Do you already plan to release this feature soon ? Do you want me to create a new Jira ticket, propose a pull request ?
Antoine