flink eventTime, lateness, maxoutoforderness

Posted by chen on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/flink-eventTime-lateness-maxoutoforderness-tp17318.html

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(TumblingEventTimeWindows.of(Time.seconds(5)))
         .allowedLateness(Time.seconds(5))
         .fold(initRow(), new MyFoldFunction())

public Watermark getCurrentWatermark() {
        return new Watermark(currentTime - 5000);}

Does anyone could explain the time of eventTime,lateness,maxoutoforderness?



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/