[
https://issues.apache.org/jira/browse/FLINK-5250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821628#comment-15821628
]
ASF GitHub Bot commented on FLINK-5250:
---------------------------------------
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/3115
[FLINK-5250] Make AbstractUdfStreamOperator aware of WrappingFunction
This PR fixes [FLINK-5250].
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/StefanRRichter/flink
CheckpointedFunctionWithWrapping
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3115.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3115
----
commit 0db9eb164379e7673fb7883e42f29a3d9cae3c91
Author: Stefan Richter <[email protected]>
Date: 2017-01-05T22:47:15Z
Handle checkpointing callbacks in wrapped functions
commit 6ca0c4b7e91cacb11ebc9c2e77d8c9df5479af8e
Author: Stefan Richter <[email protected]>
Date: 2017-01-13T11:01:55Z
Unit test
----
> Make AbstractUdfStreamOperator aware of WrappingFunction
> --------------------------------------------------------
>
> Key: FLINK-5250
> URL: https://issues.apache.org/jira/browse/FLINK-5250
> Project: Flink
> Issue Type: Improvement
> Components: Streaming
> Reporter: Aljoscha Krettek
> Assignee: Stefan Richter
>
> Right now, when using a {{WrappingFunction}}, as happens for
> {{WindowFunction}} and also for some functions in the Scala API then using
> custom interfaces is not possible. These custom interfaces are, for example,
> the checkpointing functions such as {{ListCheckpointed}} and
> {{CheckpointedFunction}}.
> We should teach {{AbstractUdfStreamOperator}} about {{WrapingFunction}} so
> that it can correctly handle the case where wrapped user functions implement
> on of these interfaces.
> Also, in the Scala API we have some custom functions that mimic
> {{WrappingFunction}} behaviour. These should be moved to use
> {{WrappingFunction}}, if possible.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
