2.0-Flink編程模型

該筆記內容&源碼與 github/flink-advanced 同步 抽象級別 Flink提供了不同級別的抽象來開發 流/批 處理應用程序。 最低級別的抽象僅提供狀態流。 通過Process Function嵌入到DataStream API中。 允許用戶自由地處理一個或多個流中的事件，並使用一致的容錯狀態。 此外，用戶可以註冊事件時間和處理時間回調，從而允許程序實現複雜的計算。 實際上，大部分程

>>阅读原文<<