WindowedStream #

WindowAssigner 设计与实现 #

WindowAssigner 结构 #

SlidingEventTimeWindows #

public static long getWindowStartWithOffset(long timestamp, long offset, long windowSize) {
    return timestamp - (timestamp - offset + windowSize) % windowSize;
}