EventTime窗口时间

基于事件时间EventTime窗口的起止时间分析时，如果Job是第1次运行，此时第一个窗口的起始时间是如何确定的？

滚动窗口：（size=5秒）

第一条数据:sid_1,success,2030-12-28 16:28:41,4

计算

第1个窗口起始时间：2030-12-28 16:28:40

滚动窗口size 5秒

计算

第1个窗口结束时间：2030-12-28 16:28:45

以此类推下一个窗口开始时间和结束时间，

第2个窗口起始时间：2030-12-28 16:28:45 -- 2030-12-28 16:28:50

第3个窗口起始时间：2030-12-28 16:28:50 -- 2030-12-28 16:28:55

时间窗口源码：[start,end)

xxxxxxxxxx
package org.apache.flink.streaming.api.windowing.windows;
......
/**
 * A {@link Window} that represents a time interval from {@code start} (inclusive) to {@code end}
 * (exclusive).
 */
@PublicEvolving
public class TimeWindow extends Window {

    private final long start;
    private final long end;

    public TimeWindow(long start, long end) {
        this.start = start;
        this.end = end;
    }
    ......
}

时间窗口的计算：

滑动窗口：(窗口大小size=10秒 > 滑动间隔slide=5秒）

第一条数据:sid_1,success,2030-12-28 16:28:41,4

计算

第1个窗口起始时间：2030-12-28 16:28:40

滚动窗口size 10秒

计算

第1个窗口结束时间：2030-12-28 16:28:50

结合窗口滑动间隔，一次计算出，下一个窗口开始时间，再计算窗口结束时间，以此类推

第2个窗口时间：2030-12-28 16:28:45 -- 2030-12-28 16:28:55

第3个窗口时间：2030-12-28 16:28:50 -- 2030-12-28 16:29:00