时间语义

Flink 支持三种时间语义：

  • 时间时间（Event Time）：数据产生的时间，是数据的自然时间。
  • 摄取时间（Inestion Time）： Flink 读取事件时记录的时间。
  • 处理时间（Processing Time）：数据被处理的时间，Flink pipeline 中具体算子处理事件的时间。

水位线（Watermark）

水位线作用：定义何时停止等待较早的事件。

窗口（Window）

窗口作用：将事件按时间或事件数量分组，用于进行聚合操作。