[
https://issues.apache.org/jira/browse/FLINK-5250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5250.
-----------------------------------
Resolution: Fixed
Fix Version/s: 1.2.0
Implemented on release-1.2 in:
8041deabe8e1e968ba724ba87f534570cdc18522
33c5df6dd0aaf604fdbc97834cfd643a43ca7d08
> 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
> Fix For: 1.2.0
>
>
> 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)
