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图解的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。