You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/01/10 14:18:59 UTC
[jira] [Commented] (FLINK-5250) Make AbstractUdfStreamOperator
aware of WrappingFunction
[ https://issues.apache.org/jira/browse/FLINK-5250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15815072#comment-15815072 ]
Aljoscha Krettek commented on FLINK-5250:
-----------------------------------------
Remember to close FLINK-5416 when we close this issue.
> 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)