Thanks Gordon, Please see the rely. I use code, but the result it doesn`t
like what the doc explain.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
CODE with maxOutOfOrdernesstime effect:
dataStream.keyBy(row -> (String)row.getField(0))
.window(TumblingEventTimeWindows.of(Time.seconds(5)))
.fold(initRow(), new FoldFunction() {
@Override
public Row fold(Row ret, Ro
Hi Eron,
Thanks for your help. Actually I know maxoutoforder, lateness is based
on Event Time. But in my test it is not. Following is my code and test data.
"key1|148325064|",
"key1|1483250636000|",
"key1|1483250649000|",
"key1|1483250642000|",
"
Hi,
lateness is record time or the real word time?
maxoutoforderness is record time or the real word time?
Both allow lateness of window operators, or maxOutOfOrderness of the
BoundedOutOfOrdernessTimestampExtractor, refer to event time.
i.e.,
- given the end timestamp of a window is x (in ev
Take a look at the section of Flink documentation titled "Event Time and
Watermarks":
https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/event_time.html#event-time-and-watermarks
Also read the excellent series "Streaming 101" and "102", has useful
animations depicting the flow of time
eventTime, lateness, maxoutoforderness are all about time.
event Time is the water mark time on the record.
lateness is record time or the real word time?
maxoutoforderness is record time or the real word time?
dataStream.keyBy(row -> (String)row.getField(0))
.window(TumblingEventTimeWind
