?

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

總結

以上是生活随笔為你收集整理的Flink中GroupWindow和OverWindow各自的作用+window体系+文档阅读方式的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。