数据工匠记 | 一个程序员的个人博客

Flink窗口起始时间计算

Flink中窗口的时间不是根据进入窗口的第一个元素计为窗口的开始时间和加Size计窗口结束时间，而是根据Flink内置计算公式`timestamp - (timestamp - offset + windowSize) % windowSize`计算。

2021-03-05 浏览(1,613) 评论(0)

Streaming 流式计算是一种被设计用于处理无限数据集的数据处理引擎，而无限数据集是指一种不断增长的本质上无限的数据集，而 window 是一种切割无限数据为有限块进行处理的手段。

2021-03-03 浏览(566) 评论(0)

Flink在流式传输程序中支持不同的时间概念和窗口

2021-01-06 浏览(1,738) 评论(0)