Aljoscha Krettek created FLINK-1967:
---------------------------------------
Summary: Introduce (Event)time in Streaming
Key: FLINK-1967
URL: https://issues.apache.org/jira/browse/FLINK-1967
Project: Flink
Issue Type: Improvement
Reporter: Aljoscha Krettek
Assignee: Aljoscha Krettek
This requires introducing a timestamp in streaming record and a change in the
sources to add timestamps to records. This will also introduce punctuations (or
low watermarks) to allow windows to work correctly on unordered, timestamped
input data. In the process of this, the windowing subsystem also needs to be
adapted to use the punctuations. Furthermore, all operators need to be made
aware of punctuations and correctly forward them. Then, a new operator must be
introduced to to allow modification of timestamps.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
