1.簡介
????????流式處理中板壮，數(shù)據(jù)連續(xù)不斷的產(chǎn)生坦喘，flink使用窗口機制將無限的數(shù)據(jù)有限化板熊，比如每5s計算一次數(shù)據(jù)中最大值阅酪、或者每5分鐘獲取過去1小時的熱門商品旨袒。
2.窗口詳解
窗口分類
????????窗口既可以是時間驅(qū)動窗口（如每5s計算一次最大值），也可以是是數(shù)據(jù)驅(qū)動（如每100個數(shù)據(jù)中的最大值）术辐。下面對每種窗口進行舉例砚尽。
2.1 滾動時間窗口（無重疊）
Tumbling Time Window
2.2 滑動時間窗口
Sliding Time Window
?window size為5s，slide size為1s辉词。
2.3 滾動計數(shù)窗口
Tumbling Count Window
2.4 滑動計數(shù)窗口
Sliding Count Window
2.5 會話窗口
Session Window
2.6 ***自動義窗口***
flink的窗口機制非常靈活必孤，可以根據(jù)需要自定義窗口，下節(jié)詳述
3. Window API?
API
根據(jù)以上api较屿，可以自定義窗口如下：
汽車每走tirggerMetters 米隧魄，計算最近evitcSec秒的最大速度
4.參考文章（非常優(yōu)秀！０９鹤摹）
http://wuchong.me/blog/2016/05/25/flink-internals-window-mechanism/
