You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/09/14 14:47:45 UTC

[jira] [Created] (FLINK-2666) Allow custom Timestamp extractors for Flink sources

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)