Flink---基本概念
阿新 • • 發佈:2019-01-06
流分類
- Unbounded streams:有起點沒終點的資料流,對應的處理操作稱為流計算;
- Bounded streams:有始有終的資料流,對應的處理操作稱為批處理;
Time
-
Event Time:事件產生的時間;
-
Ingestion time:事件進入Flink的時間;
-
Processing Time:Flink開始處理事件的時間;
Windows
視窗大小
視窗大小可以從時間或空間維度來衡量,如下圖所示:
時間視窗
Flink內建了3種時間視窗:Tumbling Windows、Sliding Windows和Session Windows;
- Tumbling Windows(滾動視窗): 視窗大小固定,沒有重疊;
- Sliding Windows(滑動視窗):視窗大小固定,有重疊;
- Session Windows(會話視窗):視窗大小不固定,沒有重疊,同一個session中所有事件分配在一個視窗;
參考: