[jira] [Created] (FLINK-9600) Add DataStream transformation variants that pass timestamp to the user function

[Shang Yuanchun (Jira)]

Elias Levy created FLINK-9600:
---------------------------------

             Summary: Add DataStream transformation variants that pass timestamp to the user function
                 Key: FLINK-9600
                 URL: https://issues.apache.org/jira/browse/FLINK-9600
             Project: Flink
          Issue Type: Improvement
          Components: Streaming
    Affects Versions: 1.5.0
            Reporter: Elias Levy


It is often necessary to access the timestamp assigned to records within user functions.  At the moment this is only possible from {{RichFunction}}. Implementing a {{RichFunction}} just to access the timestamp is burdensome, so most job carry a duplicate of the timestamp within the record.

It would be useful if {{DataStream}} provided transformation methods that accepted user functions that could be passed the record's timestamp as an additional argument, similar to how there are two variants of {{flatMap}}, one with an extra parameter that gives the user function access to the output {{Collector}}.

Along similar lines, it may be useful to have variants that pass the record's key as an additional parameter.

 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)