flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Elias Levy <fearsome.lucid...@gmail.com>
Subject Re: Behavior of time based operators
Date Fri, 03 Aug 2018 01:00:43 GMT
See the section on Operators here

On Thu, Aug 2, 2018 at 3:42 PM Harshvardhan Agrawal <
harshvardhan.agr93@gmail.com> wrote:

> Hello,
> I have recently started reading Stream Processing with Apache Flink by
> Fabian and Vasiliki. In Chapter 3 of the book there is a statement that
> says: None of the functions expose an API to set time stamps of emitted
> records, manipulate the event-time clock of a task, or emit watermarks.
> Instead, time-based DataStream operator tasks internally set the time
> stamps of emitted records to ensure that they are properly aligned with the
> emitted watermarks. For instance, a time-window operator task attached the
> end time of a window as time stamp to all records emitted by the window
> computation before it emits the watermark with the time stamp that
> triggered the computation of the window.
> Does this mean that time stamps in the records are overwritten by these
> time-based operators when using Event Time?
> --
> Regards,
> Harshvardhan

View raw message