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)
