Flink 實現實時計數和按窗口計時功能程序設計

最近在開發程序的時候,有須要實時的計數處理,以及須要按照設計的窗口來補時長,在要求選用Flink處理後,程序大體架構設計入下: 其設計思路爲:從kafk讀取數據生成DataStream[Message]這樣一箇中間變量,而後將這個中間流分兩個流,一個流用於實時計數,另外一個流,按照互動窗口,按照EventTime將消息劃分到不一樣的窗口,而後取出整個窗口的數據以及取出歷史數據,造成完整窗口的數據,

>>阅读原文<<