lling" FoldFunction” topic, one could use event
time for example for a "best effort" sorting mechanism (which buffers some
number of elements and tries to smooth the stream out/best effort sort it),
registering event time timers or for any other custom operation.
Same applies to water
.
Regards,
Min
From: Piotr Nowojski [mailto:pi...@data-artisans.com]
Sent: Freitag, 7. Dezember 2018 11:11
To: Tan, Min
Cc: user
Subject: [External] Re: Use event time
Hi again!
Flink doesn’t order/sort the records according to event time. The preveiling
idea is:
- records will be arriving out
Hi again!
Flink doesn’t order/sort the records according to event time. The preveiling
idea is:
- records will be arriving out of order, operators should handle that
- watermarks are used for indicators of the current lower bound of the event
time “clock”
For examples windowed
Hi,
I am new to Flink.
I have the following small code to use the event time. I did not get the result
expected, i.e. it print out events in the order of event time.
Did I miss something here?
Regards,
Min
--Event time--
public static void main(String[] args)