窗口創建
窗口不會預先創建好，而是由數據驅動創建。當第一個應該屬於這個窗口的數據元素到達時，就會創建對應的窗口。

窗口計算
對於不同的窗口類型，觸發計算的條件也會不同。例如，一個滾動事件時間窗口，應該在水位線到達窗口結束時間的時候觸發計算；而一個計數窗口，會在窗口中元素數量達到定義大小時觸發計算。

窗口銷燬
一般情況下，當時間達到了結束點，就會直接觸發計算、輸出結果，進而清除狀態、銷燬窗口。 這時窗口的銷燬可以認為和觸發計算是同一時刻。這裏需要注意，Flink 中只對時間窗口（TimeWindow）有銷燬機制；由於計數窗口（CountWindow）是基於全局窗口（GlobalWindow）實現的，而全局窗口不會清除狀態，所以就不會被銷燬。



2.2.4 基於窗口機制的流計算
算子模型
Flink中算子分為數據源算子（source）、轉換算子（transform）、輸出算子（sink），下圖為算子模型示意圖。數據源算子負責接收運算數據，數據源支持多種：文本、MQ等等；