Flink 时间语义详解:事件时间、处理时间和摄入时间
Flink 的时间语义包括以下几种:
-
'Event Time':事件时间是指数据本身携带的时间戳,反映了数据生成的实际时间。
-
'Processing Time':处理时间是指数据到达 Flink 系统时的本地系统时间。
-
'Ingestion Time':摄入时间是指数据进入 Flink 系统的时间。
Flink 主要使用事件时间来进行计算,因为它更能反映真实的数据处理情况。在使用事件时间时,Flink 会为每个事件分配一个时间戳,并按照时间戳进行有序处理。同时,Flink 还支持水印机制来处理事件时间的乱序,以保证数据的正确性和准确性。
原文地址: https://www.cveoy.top/t/topic/oYC2 著作权归作者所有。请勿转载和采集!