本文為您介紹如何使用實時計算Flink版會話視窗函式。

什麼是會話視窗

會話視窗（SESSION）通過SESSION活動來對元素進行分組。會話視窗與滾動視窗和滑動視窗相比，沒有視窗重疊，沒有固定視窗大小。相反，當它在一個固定的時間週期內不再收到元素，即會話斷開時，該視窗就會關閉。

會話視窗通過一個間隔時間（Gap）來配置，這個間隔定義了非活躍週期的長度。例如，一個表示滑鼠單擊活動的資料流可能具有長時間的空閒時間，並在兩段空閒之間散佈著高濃度的單擊。如果資料在指定的間隔（Gap）之後到達，則會開始一個新的視窗。

會話視窗函式語法

SESSION(<time-attr>, <gap-interval>)
<gap-interval>: INTERVAL 'string' timeUnit

會話視窗標識函式

使用標識函式選出視窗的起始時間或者結束時間，視窗的時間屬性用於下級Window的聚合。

示例

統計每個使用者在每個活躍會話期間的單擊次數，會話超時時長為30秒。

• 測試資料

  username （VARCHAR）	click_url （VARCHAR）	ts （TIMESTAMP）
  Jark	http://taobao.com/xxx	2017-10-10 10:00:00.0
  Jark	http://taobao.com/xxx	2017-10-10 10:00:10.0
  Jark	http://taobao.com/xxx	2017-10-10 10:00:49.0
  Jark	http://taobao.com/xxx	2017-10-10 10:01:05.0
  Jark	http://taobao.com/xxx	2017-10-10 10:01:58.0
  Timo	http://taobao.com/xxx	2017-10-10 10:02:10.0

• 測試語句

CREATE TABLE user_clicks(
username varchar,
click_url varchar,
ts timeStamp,
WATERMARK wk FOR ts as withOffset(ts, 2000) -- 為rowtime定義watermark
) with (
type='datahub',
...
);

CREATE TABLE session_output(
window_start TIMESTAMP,
window_end TIMESTAMP,
username VARCHAR,
clicks BIGINT
) with (
type='rds'，
...
);

INSERT INTO session_output
SELECT
SESSION_START(ts, INTERVAL '30' SECOND),
SESSION_END(ts, INTERVAL '30' SECOND),
username,
COUNT(click_url)
FROM user_clicks
GROUP BY SESSION(ts, INTERVAL '30' SECOND), username;

• 測試結果

  window_start （TIMESTAMP）	window_end （TIMESTAMP）	username （VARCHAR）	clicks （BIGINT）
  2017-10-10 10:00:00.0	2017-10-10 10:00:40.0	Jark	2
  2017-10-10 10:00:49.0	2017-10-10 10:01:35.0	Jark	2
  2017-10-10 10:01:58.0	2017-10-10 10:02:28.0	Jark	1
  2017-10-10 10:02:10.0	2017-10-10 10:02:40.0	Timo	1