Flink accumulator Counter 累加器 和 计数器

Accumulators(累加器)是很是简单的，经过一个add操做累加最终的结果，在job执行后能够获取最终结果 最简单的累加器是counter(计数器)：你能够经过Accumulator.add(V value)这个方法进行递增。在任务的最后，flink会吧全部的结果进行合并，而后把最终结果发送到client端。累加器在调试或者你想更快了解你的数据的时候是很是有用的。 Flink如今有一下内置累

>>阅读原文<<