Apache Flink 漫谈系列 - SQL概览

Tumble 转动窗口有牢靠size，窗口数据不重叠,详细语义如下：

b. 语法

Tumble 转动窗口对应的语法如下：

SELECT 
[gk], 
[TUMBLE_START(timeCol, size)], 
[TUMBLE_END(timeCol, size)], 
agg1(col1), 
... 
aggn(colN) 
FROM Tab1 
GROUP BY [gk], TUMBLE(timeCol, size) 

• [gk] - 抉择了流是Keyed照旧/Non-Keyed;
• TUMBLE_START - 窗口开始时刻;
• TUMBLE_END - 窗口竣事时刻;
• timeCol - 是流表中暗示时刻字段;
• size - 暗示窗口的巨细，如 秒，分钟，小时，天。

c. SQL 示例

操作pageAccess_tab测试数据，我们必要按差异区域统计每2分钟的淘宝首页的会见量(PV)。

SELECT 
region, 
TUMBLE_START(rowtime, INTERVAL '2' MINUTE) AS winStart, 
TUMBLE_END(rowtime, INTERVAL '2' MINUTE) AS winEnd, 
COUNT(region) AS pv 
FROM pageAccess_tab 
GROUP BY region, TUMBLE(rowtime, INTERVAL '2' MINUTE) 

d. Result

(2) Hop

Hop 滑动窗口和转动窗口相同，窗口有牢靠的size，与转动窗口差异的是滑动窗口可以通过slide参数节制滑动窗口的新建频率。因此当slide值小于窗口size的值的时辰多个滑动窗口会重叠。

a. 语义

Hop 滑动窗口语义如下所示：

b. 语法

Hop 滑动窗口对应语法如下：

SELECT 
[gk], 
[HOP_START(timeCol, slide, size)] , 
[HOP_END(timeCol, slide, size)], 
agg1(col1), 
... 
aggN(colN) 
FROM Tab1 
GROUP BY [gk], HOP(timeCol, slide, size) 

• [gk] 抉择了流是Keyed照旧/Non-Keyed;
• HOP_START - 窗口开始时刻;
• HOP_END - 窗口竣事时刻;
• timeCol - 是流表中暗示时刻字段;
• slide - 是滑动步骤的巨细;
• size - 是窗口的巨细，如 秒，分钟，小时，天;

c. SQL 示例

操作pageAccessCount_tab测试数据，我们必要每5分钟统计近10分钟的页面会见量(PV).

SELECT 
HOP_START(rowtime, INTERVAL '5' MINUTE, INTERVAL '10' MINUTE) AS winStart, 
HOP_END(rowtime, INTERVAL '5' MINUTE, INTERVAL '10' MINUTE) AS winEnd, 
SUM(accessCount) AS accessCount 
FROM pageAccessCount_tab 
GROUP BY HOP(rowtime, INTERVAL '5' MINUTE, INTERVAL '10' MINUTE) 

（编辑：湖南网）

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