Flink編程模型

4.1 抽象的層級 有狀態的數據流處理層。最底層的抽象僅僅提供有狀態的數據流，它通過處理函數（Process Function）嵌入到數據流api(DataStream API). 用戶可以通過它自由的處理單流或者多流，並保持一致性和容錯。同時用戶可以註冊事件時間和處理時間的回調處理，以實現複雜的計算邏輯。 核心API層，DataSet 處理有界的數據集，DataStream 處理有界或者無界的數

>>阅读原文<<