You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Robert Metzger (JIRA)" <ji...@apache.org> on 2019/02/28 11:13:01 UTC
[jira] [Updated] (FLINK-9600) Add DataStream transformation
variants that pass timestamp to the user function
[ 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)