Apache Flink 漫谈系列 - SQL概览

我们以3个元素(2 PRECEDING)的窗口为例，如下图：

上图所示窗口 user 1 的 w5和w6， user 2的 窗口 w2 和 w3，固然有元素都是统一时候达到，可是他们如故是在差异的窗口，这一点有别于RANGE OVER Window。

b. 语法

Bounded ROWS OVER Window 语法如下：

SELECT 
agg1(col1) OVER( 
[PARTITION BY (value_expression1,..., value_expressionN)] 
ORDER BY timeCol 
ROWS 
BETWEEN (UNBOUNDED | rowCount) PRECEDING AND CURRENT ROW) AS colName, 
... 
FROM Tab1 

• value_expression - 举办分区的字表达式;
• timeCol - 用于元素排序的时刻字段;
• rowCount - 是界说按照当前行开始向前追溯几行元素。

c. SQL 示例

操作item_tab测试数据，我们统计同类商品中当前和当前商品之前2个商品中的最高价值。

SELECT 
itemID, 
itemType, 
onSellTime, 
price, 
MAX(price) OVER ( 
PARTITION BY itemType 
ORDER BY onSellTime 
ROWS BETWEEN 2 preceding AND CURRENT ROW) AS maxPrice 
FROM item_tab 

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的语法如下：

SELECT 
agg1(col1) OVER( 
[PARTITION BY (value_expression1,..., value_expressionN)] 
ORDER BY timeCol 
RANGE 
BETWEEN (UNBOUNDED | timeInterval) PRECEDING AND CURRENT ROW) AS colName, 
... 
FROM Tab1 

• value_expression - 举办分区的字表达式;
• timeCol - 用于元素排序的时刻字段;
• timeInterval - 是界说按照当前行开始向前追溯指按时刻的元素行;

c. SQL 示例

（编辑：湖南网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!