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 示例

（编辑：湖南网）

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