Apache Flink v1.8（概念-數據流編程模型）

抽象層次 Flink提供了不同級別的抽象來開發流/批處理應用程序。 最低級抽象只提供有狀態流。它通過Process Function嵌入到DataStream API中。它允許用戶自由處理來自一個或多個流的事件，並使用一致的容錯狀態。此外，用戶可以註冊事件時間和處理時間回調，允許程序實現複雜的計算。 在實踐中，大多數應用程序不需要上述低級抽象，而是針對Core API編程， 如DataStream

>>阅读原文<<