窗口的概念
我们知道Flink是一个可以处理无限流的流式处理引擎，无限流有个特点就是数据无休无止，源源不断，这种情况下要是想做统计聚合的话，就没有数据的尽头，因为数据在一直不停的更新。
在这种情况下，业务就想看之前一个小时或者一天的数据，就需要人为的给无界流增加一个界限，一个范围...
2年前 (2022-12-20) 2583℃
5喜欢
Flink中的时间语义
如上图所示，在事件发生之后，生成的数据被收集起来，首先进入消息队列，然后被Flink系统中的Source算子读取消费，进而向下游的转换算子传递，最终由窗口进行计算处理。
很明显这里面有两个时间点
Event Time：是事件创建的时间，叫...
2年前 (2022-12-20) 1377℃
0喜欢
