【Flink】时间语义和Watermark
SQLBoy | 1073 | 2022-02-15
时间语义
时间语义容易理解,就是三个时间
- EventTime (事件时间)
事件创建时间,一般是用时间戳表示
- Ingestion Time (摄入时间)
数据进入Flink的时间
- Processing Time (处理时间)
执行算子的时间
WaterMark
中文称呼就是 水位线
出现水位线的目的: 解决EventTime 时间乱序问题。
需要深入了解下 水位线,这个也是面试中必会问及的知识点。
是一个触发机制,一旦到达水位线,窗口就会立马进行计算。
推荐指数:
4人已点赞

