[
https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339101#comment-16339101
]
Antoine Philippot commented on FLINK-6756:
------------------------------------------
Hi [~aljoscha] and [~spi-x-i]
I have started to implement the Aljoscha idea.
This is my current commit
[https://github.com/apache/flink/commit/96684058d4a209d39d7fb1667beb7f083d215b58]
My only concern is about override setRuntimeContext
[https://github.com/apache/flink/commit/96684058d4a209d39d7fb1667beb7f083d215b58#diff-e79f7947628990ee5298af04bca1c399R17]
compared to ScalaProcessWindowFunctionWrapper
[https://github.com/apache/flink/blob/master/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/function/util/ScalaProcessWindowFunctionWrapper.scala#L86]
I don't understand the both call super.setRuntimeContext(t) and
rfunc.setRuntimeContext(t)
What do you think about that ?
> Provide RichAsyncFunction to Scala API suite
> --------------------------------------------
>
> Key: FLINK-6756
> URL: https://issues.apache.org/jira/browse/FLINK-6756
> Project: Flink
> Issue Type: Improvement
> Components: DataStream API
> Reporter: Andrea Spina
> Assignee: Andrea Spina
> Priority: Major
>
> I can't find any tracking info about the chance to have RichAsyncFunction in
> the Scala API suite. I think it'd be nice to have this function in order to
> access open/close methods and the RuntimeContext.
> I was able to retrieve
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/There-is-no-Open-and-Close-method-in-Async-I-O-API-of-Scala-td11591.html#a11593
> only, so my question is if there are some blocking issues avoiding this
> feature. [~till.rohrmann]
> If it's possible and nobody already have done it, I can assign the issue to
> myself in order to implement it.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
