【Flink】时间语义和Watermark

SQLBoy | 1073 | 2022-02-15

时间语义

时间语义容易理解,就是三个时间

  • EventTime (事件时间)

事件创建时间,一般是用时间戳表示

  • Ingestion Time (摄入时间)

数据进入Flink的时间

  • Processing Time (处理时间)

执行算子的时间

WaterMark

中文称呼就是 水位线
出现水位线的目的: 解决EventTime 时间乱序问题。

需要深入了解下 水位线,这个也是面试中必会问及的知识点。
是一个触发机制,一旦到达水位线,窗口就会立马进行计算。

文章标签: 大数据
推荐指数:

4人已点赞

【Flink】时间语义和Watermark

关于作者 📝

SQLBoy

简简单单 SQLBoy

等级 LV1

粉丝 4

获赞 10

经验 14

【Flink】时间语义和Watermark

评论