时间语义(Notions of Time)
https://blog.csdn.net/lomodays207/article/details/109642581
在Flink中,由于处理时间比较简单,早期版本默认的时间语义是处理时间;而考虑到事件时间在实际应用中更为广泛,从 1.12版本 开始 Flink已经将 事件时间作为了默认的时间语义。
1.处理时间( Processing Time)
处理时间的概念非常简单,就是指执行处理操作的机器的系统时间。
2.事件时间( Event Time)
事件时间,是指每个事件在对应的设备上发生的时间,也就是数据生成的时间。
3 摄入时间( Ingestion Time)
它是指数据进入 Flink数据流的时间,也就是 Source算子读入数据的时间。
时间语义(Notions of Time)
# Related Post
1.任务生成和分配
2.任务槽 task slots
3.算子链
4.容错机制
5.watermark(水位线)
6.处理无界和有界数据
7.flink部署
8.Flink架构原理
1.任务生成和分配
2.任务槽 task slots
3.算子链
4.容错机制
5.watermark(水位线)
6.处理无界和有界数据
7.flink部署
8.Flink架构原理