第一个窗口触发时间
Posted kris12
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了第一个窗口触发时间相关的知识，希望对你有一定的参考价值。
窗口的第一个时间窗口是如何定义的呢？查看源码：
滑动窗口：
这里的offset是用来指定时间戳的时区的，timestamp（1970年1月1号的毫秒数，默认是格林威治0时区的时间），北京时间是东八区，我们的时间比他们早8h，如果要跟他们标准时间统一的话offset应该是 -8；但在国内无所谓的，默认offset = 0。这里的windowSize是slide，上一步传进来的值（即windowSize 是滑动步长）
如果watermark = 1s, 窗口大小15s,步长5s；
比如第一个进来的事件时间的时间戳为1547718199 ：
1547718199 - (1547718199 + 5) % 5 = 1547718195
即第一个window： [195, 210)，但实际中到200的时间已经关了
lastStart最近的一次起点，lastStart = 195，for循环追加了好几个window：195 > 199 - 15 = 184 ---> windows.add （195， 210）
190（195-5） > 184 ----> （190，205）
185 > 184 -------> （185，200）
[195, 210)、[200, 215)、[205, 220)
滚动步长源码：
直接195开始，210结束。而滑动窗口，如上是195开始，200就第一个结束啦；
以上是关于第一个窗口触发时间的主要内容，如果未能解决你的问题，请参考以下文章