flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Robert Metzger (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-4796) Extend SinkFunction to include also the event timestamp
Date Tue, 11 Oct 2016 08:20:20 GMT
Robert Metzger created FLINK-4796:

             Summary: Extend SinkFunction to include also the event timestamp
                 Key: FLINK-4796
                 URL: https://issues.apache.org/jira/browse/FLINK-4796
             Project: Flink
          Issue Type: Improvement
          Components: DataStream API
    Affects Versions: 1.2.0
            Reporter: Robert Metzger

The Kafka 0.10 connector supports writing event timestamps to Kafka.
Currently, the regular DataStream APIs don't allow user code to access the event timestamp
easily. That's why the Kafka connector is using a custom operator ({{transform()}}) to access
the event time.

With this JIRA, I would like to provide the event timestamp in the regular DataStream APIs.

Once I'll look into the issue, I'll post some proposals how to add the timestamp. 

This message was sent by Atlassian JIRA

View raw message