Flink累加器的使用(accumulator)

Flink的Accumulator即累加器，與Saprk Accumulator 的應用場景差很少，都能很好地觀察task在運行期間的數據變化 能夠在Flink job任務中的算子函數中操做累加器，可是隻能在任務執行結束以後才能得到累加器的最終結果。spark的累加器用法.javascript Flink中累加器的用法很是的簡單:java 1：建立累加器：      val acc = new I

>>阅读原文<<