Apache Flink 漫谈系列(13) - Table API 概述

Hop 滑动窗口和滚动窗口类似，窗口有固定的size，与滚动窗口不同的是滑动窗口可以通过slide参数控制滑动窗口的新建频率。因此当slide值小于窗口size的值的时候多个滑动窗口会重叠。

• 语义

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

• Table API 示例

利用pageAccessCount_tab测试数据，我们需要每5分钟统计近10分钟的页面访问量(PV).

val result = pageAccessCount 
.window(Slide over 10.minute every 5.minute on 'rowtime as 'w) 
.groupBy('w) 
.select('w.start, 'w.end, 'accessCount.sum as 'accessCount) 

• Result

(c) Session

Seeeion 会话窗口 是没有固定大小的窗口，通过session的活跃度分组元素。不同于滚动窗口和滑动窗口，会话窗口不重叠,也没有固定的起止时间。一个会话窗口在一段时间内没有接收到元素时，即当出现非活跃间隙时关闭。一个会话窗口 分配器通过配置session gap来指定非活跃周期的时长.

• 语义

Session 会话窗口语义如下所示：

val result = pageAccessSession 
.window(Session withGap 3.minute on 'rowtime as 'w) 
.groupBy('w, 'region) 
.select('region, 'w.start, 'w.end, 'region.count as 'pv) 

• Result

(d) 嵌套Window

在Window之后再进行Window划分也是比较常见的统计需求，那么在一个Event-Time的Window之后，如何再写一个Event-Time的Window呢?一个Window之后再描述一个Event-Time的Window最重要的是Event-time属性的传递，在Table API中我们可以利用'w.rowtime来传递时间属性，比如：Tumble Window之后再接一个Session Window 示例如下:

... 
val result = pageAccess 
.window(Tumble over 2.minute on 'rowtime as 'w1) 
.groupBy('w1) 
.select('w1.rowtime as 'rowtime, 'col1.count as 'cnt) 
.window(Session withGap 3.minute on 'rowtime as 'w2) 
.groupBy('w2) 
.select('cnt.sum) 
... 

五、Source&Sink

（编辑：宁波网）

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