Flink 有狀態的算子和應用程序

流式計算分爲無狀態和有狀態兩種情況。無狀態的計算觀察每個獨立事件，並根據最後一個事件輸出結果。例如，流處理應用程序從傳感器接收水位數據，並在水位超過指定高度時發出警告。有狀態的計算則會基於多個事件輸出結果。以下是一些例子。 所有類型的窗口。例如，計算過去一小時的平均水位，就是有狀態的計算。 所有用於複雜事件處理的狀態機。例如，若在一分鐘內收到兩個相差20cm以上的水位差讀數，則發出警告，這是有狀態

>>阅读原文<<