flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-2666) Allow custom Timestamp extractors for Flink sources
Date Sun, 04 Oct 2015 08:24:26 GMT

    [ https://issues.apache.org/jira/browse/FLINK-2666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14942592#comment-14942592
] 

ASF GitHub Bot commented on FLINK-2666:
---------------------------------------

Github user aljoscha commented on the pull request:

    https://github.com/apache/flink/pull/1201#issuecomment-145327337
  
    I ran 10 more travis builds and I didn't see any problem, so this should be good to merge.


> 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
>            Assignee: Aljoscha Krettek
>            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)

Mime
View raw message