Flink 时间语义
2023-09-02 10:07:58 5 举报Flink 时间语义
作者其他创作
大纲/内容
KeyByedStream()调用font color=\"#000000\
处理时间 ProcessTime知道此事的时间 正在执行相应操作的系统时间实时程序基于处理时间时 所有基于时间的操作都将使用运行机器的系统时间处理时间是最简单的概念 不需要流和机器之间的协调 提供了最佳的性能和最低延迟！注意：分布式和异步环境下 机器的系统时间可能有误差 处理时间不准确
摄入时间 IngestionTime：摄入时间指的是数据进入 Flink 的时间
代码实现
1.12之后EventTime-->作为默认的时间语义
1.12之前ProcessTime-->作为默认的时间语义
事件时间 EventTime事件真实发生的时间 事件时间一般在进入Flink之前嵌入记录中 可以从每个记录中提取事件时间戳事件时间进度机制：事件时间中 时间的进展取决于数据 不是任何挂钟 必须指定如何生成事件事件时间水印对于乱序 延时 数据重放 都能给正确的结果
environment.setStreamCharacteristic(TimeCharacteristic.xx)
时间语义为窗口计算而服务
0 条评论
下一页
