道里网站运营培训,网站域名做固定资产怎么处理,进入公众号主页,免费 网站源码什么是时间语义
Flink支持三种不同的时间语义#xff0c;以便处理流式数据中的事件时间、处理时间和摄入时间。
1. 处理时间#xff08;Processing Time#xff09;
处理时间的概念非常简单#xff0c;就是指执行处理操作的机器的系统时间。 在这种时间语义下处理窗口非…什么是时间语义
Flink支持三种不同的时间语义以便处理流式数据中的事件时间、处理时间和摄入时间。
1. 处理时间Processing Time
处理时间的概念非常简单就是指执行处理操作的机器的系统时间。 在这种时间语义下处理窗口非常简单粗暴不需要各个节点之间进行协调同步也不需要 考虑数据在流中的位置简单来说就是“我的地盘听我的”。所以处理时间是最简单的时间语义。
2. 事件时间Event Time
事件时间是指每个事件在对应的设备上发生的时间也就是数据生成的时间。 数据一旦产生这个时间自然就确定了所以它可以作为一个属性嵌入到数据中。这其实 就是这条数据记录的“时间戳”Timestamp。
3.摄入时间Ingestion Time
摄入时间是事件进入Flink系统的时间戳表示数据被Flink系统摄入的时间。摄入时间允许在不引入水印的情况下执行基于时间的操作。它适用于对事件时间不敏感的应用但仍需要按顺序处理事件的情况。摄入时间不会考虑事件本身的时间戳而是依赖于Flink系统在数据到达时记录时间。
处理时间与事件时间的比较
通常来说处理时间是我们计算效率的衡量标准而事件时间会更符合我们的业务计算逻 辑。所以更多时候我们使用事件时间不过处理时间也不是一无是处。对于处理时间而言由于没有任何附加考虑数据一来就直接处理因此这种方式可以让我们的流处理延迟降到最低 效率达到最高。
