Flink时间语义的分析:有哪些时间语义,有哪些使用场景 flink时间语义有三种:

发布于 2021-04-23 17:04:25
【多选题】
A Event Time:事件创建的时间(需要使用数据自身带的时间进行分析计算处理时设置)
B Ingestion Time:数据进入Flink的时间(存在多个 Source Operator 的情况下,每个 Source Operator可以使用自己本地系统时钟指派 Ingestion Time。后续基于时间相关的各种操作,都会使用数据记录中的 Ingestion Time)
C Processing Time:执行操作算子的本地系统时间,与机器相关(没有事件时间的情况下,或者对实时性要求超高的情况下使用,最好的性能和最低的延迟, 但是分布式和异步环境下,不能提供确定性(不能保证结果数据的准确性),容易受到事件到达系统的速度(如消息队列)、事件在系统内操作流动的速度和中断的影响) 比如要使用数据中的时间作为实时计算,则需要设置时间语义为EventTime 然后在代码中设置具体的时间字段时间戳

查看更多

关注者
0
被浏览
166
  • 体验AI问答!更聪明、超智能!
  • 一款基于GPT的超级AI助手,可以对话、创作、写文案!
1 个回答

撰写答案

请登录后再发布答案,点击登录

发布
问题

手机
浏览

扫码手机浏览

分享
好友

在线
客服