Flink中GroupWindow和OverWindow各自的作用+window体系+文档阅读方式

 

GroupWindow和OverWindow各自的作用

Flink Window	作用	完整实例
GroupWindow	对window中的数据按照字段进行分组	完整案例
OverWindow	在整个Window的条件下，对数据进行统计操作等	完整案例

相干window体系知识图谱

文档阅读方式

我们在官方文档[1]中会看到下面这种写法

Table table = input
  .window([OverWindow w].as("w"))           // define over window with alias w
  .select($("a"), $("b").sum().over($("w")), $("c").min().over($("w"))); // aggregate over the over window w

注意文档中的[OverWindow w].并不是具体的代码，只是官方一种简化偷懒的写法。

具体的写法是(文档[1]的下方):

Table orders = tableEnv.from("Orders");
Table result = orders
    // define window
    .window(
        Over
          .partitionBy($("a"))
          .orderBy($("rowtime"))
          .preceding(UNBOUNDED_RANGE)
          .following(CURRENT_RANGE)
          .as("w"))
    // sliding aggregate
    .select(
        $("a"),
        $("b").avg().over($("w")),
        $("b").max().over($("w")),
        $("b").min().over($("w"))
    );

 

Reference:

[1]Table API