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