Re: Use event time

2018-12-07 Thread Piotr Nowojski
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

RE: Re: Use event time

2018-12-07 Thread min.tan
. 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

Re: Use event time

2018-12-07 Thread Piotr Nowojski
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

Use event time

2018-12-07 Thread min.tan
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)