Apache Flink 漫谈系列 - SQL概览

d. Result

(3) Session

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

a. 语义

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

b. 语法

Seeeion 会话窗口对应语法如下：

SELECT  
    [gk],  
    SESSION_START(timeCol, gap) AS winStart,   
    SESSION_END(timeCol, gap) AS winEnd, 
    agg1(col1), 
     ...  
    aggn(colN) 
FROM Tab1 
GROUP BY [gk], SESSION(timeCol, gap) 

• [gk] 决定了流是Keyed还是/Non-Keyed;
• SESSION_START - 窗口开始时间;
• SESSION_END - 窗口结束时间;
• timeCol - 是流表中表示时间字段;
• gap - 是窗口数据非活跃周期的时长;

c. SQL 示例

（编辑：晋中站长网）

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