FLink的窗口機制與流處理Join的方案

FLink底層引擎是一個流式引擎，支持流處理和批處理，而window是streaming到batch的橋樑。由於流處理過程當中，數據是源源不斷流進來的，須要對數據進行實時處理的話，能夠經過來一個消息處理一個的方式，也能夠經過把一段時間內的數據聚合以後，再一塊兒處理的形式，此時須要定義一個窗口來收集過去那段時間內的數據再進行處理。緩存 Flink 提出了三種時間的概念，分別是event time（事

>>阅读原文<<