窗口分类

1、Time-based Window(基于时间窗口)

  • Tumbling window
  • Sliding window

2、Count-Based Window(基于数量窗口)

  • Tumbling window
  • Sliding window

3、Session Window

4、全局窗口
Flink基础学习(一)
Flink基础学习(一)
Flink基础学习(一)

时间

  • ProcessTime(处理时间)
    执行操作的机器的当前系统时间(每个算子不一样)
  • EventTime(事件事件)
    事件生成时的事件,在进入flink时已经存在,可以在event的字段中抽取
  • IngestionTime(摄入时间)
    事件进入flink的时间,即在source里获取的当前系统时间,后续操作统一使用该时间
    Flink基础学习(一)

相关文章: