Flink累加器的使用(accumulator)

Flink的Accumulator即累加器，與Saprk Accumulator 的應用場景差不多，都能很好地觀察task在運行期間的數據變化 可以在Flink job任務中的算子函數中操作累加器，但是隻能在任務執行結束之後才能獲得累加器的最終結果。spark的累加器用法. Flink中累加器的用法非常的簡單: 1：創建累加器：      val acc = new IntCounter(); 2

>>阅读原文<<