Apache Flink 官方文檔翻譯之編程模型

本文基於Apache Flink 1.3 版本官方文檔翻譯。 抽象層次 Flink 能夠爲流式計算或批處理應用提供多種層次的抽象接口。 最低級的抽象接口是狀態化的數據流接口。這個接口是通過 ProcessFunction 集成到 數據流 API 中的。此類接口讓用戶可以使用連續的容錯狀態，並且可以不受限制地處理多個數據流中的事件。另外，用戶也可以通過註冊事件時間和時間處理回調函數的方法來實現複雜的

>>阅读原文<<