[
https://issues.apache.org/jira/browse/FLINK-9600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-9600:
----------------------------------
Component/s: (was: Streaming)
API / DataStream
> 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: API / DataStream
> Affects Versions: 1.5.0
> Reporter: Elias Levy
> Priority: Minor
>
> 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)
