Flink編程模型

Flink抽象的層次 Flink爲流式計算和批處理計算編程提供了不同層次的抽象。 最底層的抽象僅僅提供有狀態的流處理，通過Process Function嵌入到DataStream API中。開發者可以處理來自多個數據流的事件，使用Flink提供的容錯機制，此外也允許開發者註冊事件時間和處理時間回調，以便實現複雜的計算邏輯。 事實上大部分程序並不會直接使用Statefull Stream Proc

>>阅读原文<<