Flink SQL Client中的session window图解

flink sql cookbook中的sql语句是:

SELECT userid,SESSION_START(log_time, INTERVAL '10' SECOND) AS session_beg,SESSION_ROWTIME(log_time, INTERVAL '10' SECOND) AS session_end,COUNT(request_line) AS request_cnt FROM server_logs WHERE status_code = '403' GROUP BY userid, SESSION(log_time, INTERVAL '10' SECOND);

session window

SQL语句详解

SQL语句的各个部分	解释
SELECT     userid,	选择userid
SESSION_START(log_time, INTERVAL '10' SECOND) AS session_beg,	session window的起始时间
SESSION_ROWTIME(log_time, INTERVAL '10' SECOND) AS session_end,	session window的结束时间
COUNT(request_line) AS request_cnt FROM server_logs WHERE status_code = '403'	用户请求遭遇403的次数统计
GROUP BY    userid,    SESSION(log_time, INTERVAL '10' SECOND);	各个用户(userid)的各个session 分开统计(count)，统计结果互不干扰

注意SQL中的'10' second必须保持一致，否则SQL会无法运行

 

运行结果:

 

 

 

 

总结

以上是生活随笔为你收集整理的Flink SQL Client中的session window图解的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。