[jira] [Created] (FLINK-4796) Extend SinkFunction to include also the event timestamp

[Shang Yuanchun (Jira)]

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
(v6.3.4#6332)