ASF GitHub Bot commented on FLINK-5250:

GitHub user StefanRRichter opened a pull request:


    [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 

Alternatively you can review and apply these changes as the patch at:


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 <s.rich...@data-artisans.com>
Date:   2017-01-05T22:47:15Z

    Handle checkpointing callbacks in wrapped functions

commit 6ca0c4b7e91cacb11ebc9c2e77d8c9df5479af8e
Author: Stefan Richter <s.rich...@data-artisans.com>
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

Reply via email to