[jira] [Created] (FLINK-5416) Function wrappers should support CheckpointedFunction

["Eron Wright (JIRA)" <ji...@apache.org>]

Eron Wright  created FLINK-5416:
-----------------------------------

             Summary: Function wrappers should support CheckpointedFunction 
                 Key: FLINK-5416
                 URL: https://issues.apache.org/jira/browse/FLINK-5416
             Project: Flink
          Issue Type: Bug
          Components: State Backends, Checkpointing
            Reporter: Eron Wright 



The `CheckpointedFunction` interface was introduced to provide user functions with a context for partitioned state storage.   This works for user functions that are provided directly to the operator (assuming it extends from `AbstractUdfStreamOperator`).   However, I see that some operators wrap the user function in an internal function (e.g. `WrappingFunction`,  `InternalWindowFunction`).   This defeats the callbacks on `CheckpointedFunction` because those wrappers don’t implement `CheckpointedFunction`. 

For example, the user function passed to `WindowedStream::apply` will get callbacks for `RichFunction` but not for `CheckpointedFunction`.





--
This message was sent by Atlassian JIRA
(v6.3.4#6332)