不带时间窗口的的groupby 会来一条数据进行一条数据的更新操作。这个时候结果是incrment的状态,每次都是覆盖(包含)了上次的结果。

Flink GroupBy与Window的关系



带时间窗口的groupby 会对时间窗口内的一批数据进行处理。这个结果是segment的状态,与窗口个数对应。

Flink GroupBy与Window的关系

相关文章:

  • 2022-12-23
  • 2022-03-07
  • 2021-07-31
  • 2022-02-05
  • 2021-06-26
  • 2022-12-23
  • 2022-12-23
  • 2021-10-29
猜你喜欢
  • 2022-12-23
  • 2022-12-23
  • 2021-04-28
  • 2021-08-05
  • 2021-04-09
  • 2021-09-12
相关资源
相似解决方案