Flink 的时间语义与Wartermark

1.Flink中的时间语义     在Flink的流式处理中,会涉及到时间的不同概念,如下图所示:     Event Time:是事件创建的时间。它通常由事件中的时间戳描述,例如采集的日志数据中,每一条日志都会记录自己的生成时间,Flink通过时间戳分配器访问事件时间戳。     Ingestion Time:是数据进入Flink的时间。     Processing Time:是每一个执行基于
相关文章
相关标签/搜索