1 个回答
Flink SQL中,处理时间(Processing Time)和事件时间(Event Time)核心区别在于时间基准的来源和如何处理乱序数据。
1、时间基准不同
1、时间基准不同
处理时间:基于机器的系统时钟(即当前物理时间)。例如,窗口的划分以任务运行的实际时间为准。
事件时间:基于数据本身携带的时间戳(即事件实际发生的时间)。例如,日志中的event_timestamp字段。
2、数据依赖性处理时间无需依赖数据内容,仅依赖系统时钟;事件时间需依赖数据中的时间戳字段,并需配合Watermark处理乱序。
3、乱序数据处理处理时间假设数据按到达顺序处理,无法处理乱序或延迟数据。
事件时间通过Watermark机制容忍乱序,标记事件时间的进展,并允许窗口延迟触发。
发布于:1周前 (05-28) IP属地:
我来回答
您需要 登录 后回答此问题!