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)
