流分類

• 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中所有事件分配在一個視窗；
  

參考：

1. Flink官網：https://ci.apache.org/projects/flink/flink-docs-release-1.7/concepts/programming-model.html#time
2. https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/stream/operators/windows.html#tumbling-windows