Flink accumulator Counter 累加器 和 計數器

Accumulators(累加器)是很是簡單的，經過一個add操做累加最終的結果，在job執行後能夠獲取最終結果 最簡單的累加器是counter(計數器)：你能夠經過Accumulator.add(V value)這個方法進行遞增。在任務的最後，flink會吧全部的結果進行合併，而後把最終結果發送到client端。累加器在調試或者你想更快了解你的數據的時候是很是有用的。 Flink如今有一下內置累

>>阅读原文<<