Apache Flink 漫谈系列 - SQL概览
我们以3个元素(2 PRECEDING)的窗口为例,如下图: 上图所示窗口 user 1 的 w5和w6, user 2的 窗口 w2 和 w3,虽然有元素都是同一时刻到达,但是他们仍然是在不同的窗口,这一点有别于RANGE OVER Window。 b. 语法 Bounded ROWS OVER Window 语法如下:
c. SQL 示例 利用item_tab测试数据,我们统计同类商品中当前和当前商品之前2个商品中的最高价格。
d. Result (2) Bounded RANGE OVER Window Bounded RANGE OVER Window 具有相同时间值的所有元素行视为同一计算行,即,具有相同时间值的所有行都是同一个窗口。 a. 语义 我们以3秒中数据(INTERVAL '2' SECOND)的窗口为例,如下图: 注意: 上图所示窗口 user 1 的 w6, user 2的 窗口 w3,元素都是同一时刻到达,他们是在同一个窗口,这一点有别于ROWS OVER Window。 b. 语法 Bounded RANGE OVER Window的语法如下:
c. SQL 示例 (编辑:我爱故事小小网_铜陵站长网) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |