Flink中的时间语义是什么?

提问者:帅平 问题分类:面试刷题
Flink中的时间语义是什么?
1 个回答
短发也倾城べ为谁留
短发也倾城べ为谁留
Spark Streaming 的微批处理架构和批处理架构本质上是一致的,只不过对用户隐藏了前两步(摄取和存储),并将每份微批数据用预写日志(而不是文件)的形式存储在内存中。而 Flink 也同样如此,在Flink中也可以看作以时间为单位,把事件流分割为一批批的任务(窗口机制)。Flink中支持两种时间语义,分别是:
1、Processing Time
1、集群服务的时间
2、处理数据节点的本地时间
3、处理简单
4、结果不确定(无法重现)
2、Event Time
1、数据本身携带的或生成的时间
2、记录携带的Timestamp
3、处理复杂
4、结果确定(可重现)
发布于:3个月前 (02-06) IP属地:四川省
我来回答