(四)Apache Flink 基本概念 — 編程模型

Flink 數據流編程模型 1. 抽象級別 Flink 提供了不同級別的抽象,以開發流或批處理作業。 最底層級的抽象僅僅提供了有狀態流,它將通過過程函數(Process Function)被嵌入到 DataStream API 中。它允許用戶可以自由地處理來自一個或多個數據流的事件,並使用一致的容錯的狀態,除此之外,用戶可以註冊事件事件並處理時間回調,從而使程序可以處理複雜的計算。 實際上,大多數
相關文章
相關標籤/搜索