Flink ---窗口机制

背景   在流计算中,数据流是无限的,没法直接进行计算,所以Flink提出了window的概念(若干元素的集合)做为流计算的基本单元进行数据处理。html 窗口机制   窗口机制实质上是Flink的算子operator对数据流的处理过程:数据流如何被拆分红window,什么时候触发计算逻辑等,以下图所示。   处理过程: 当数据流中的元素到达算子operator后,首先由WindowAssigne
相关文章
相关标签/搜索