Flink实战系列Flink SQL 之 Session Window 的用法

Posted 2022-05-09 JasonLee-后厂村程序员

Flink SQL 之 Session Window 的用法

Session Windows

会话窗口分配器按活动的会话对元素进行分组。与翻滚窗口和滑动窗口相比，会话窗口没有重叠，也没有固定的开始和结束时间。相反，当会话窗口在一段时间内没有接收到元素时，即当不活动的间隙发生时，会话窗口将关闭。会话窗口赋值器可以配置为静态会话间隙，也可以配置为会话间隙提取器函数，该函数定义了不活动的时间长度。当此期间结束时，当前会话关闭，随后的元素被分配给一个新的会话窗口。

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-mKPBZOIj-1651926181791)(/Users/jasonlee/Library/Application Support/typora-user-images/image-20220507194155609.png)]

Session window 最典型的使用场景，比如用户在手机上打开京东 app 进行了一系列的操作（搜索，点击，收藏，加入购物车，购买，支付等）这些操作产生的日志都会上传到服务器上进行用户行为分析，用户的行为是分段的，但是每一段都是连续的，这就是 session window。

Group Window Functions

SESSION(time_attr, interval)	SESSION(time attr, interval) 定义会话时间窗口。会话时间窗口没有固定的持续时间，但它们的边界由不活动的时间

创作打卡挑战赛 赢取流量/现金/CSDN周边激励大奖