Gyula Fora created FLINK-2666:
---------------------------------
Summary: Allow custom Timestamp extractors for Flink sources
Key: FLINK-2666
URL: https://issues.apache.org/jira/browse/FLINK-2666
Project: Flink
Issue Type: Improvement
Components: Streaming
Reporter: Gyula Fora
Priority: Minor
When record timestamps are turned on users currently have 2 ways of specifying
record timestamps.
They can either chose to automatically attach ingress timestamps (and send
watermarks), or custom implement a sourcefunction to manually assign timestamps
and emit watermarks.
It would be good if users could define a Timestamp extractor function that will
attach a timestamp for every record generated using any of the current Flink
sources. Also watermarks for these records should be automatically generated
based on the extracted event time (assuming monotonicity per source)
periodically.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
