Flink累加器的使用(accumulator)

Flink的Accumulator即累加器,与Saprk Accumulator 的应用场景差很少,都能很好地观察task在运行期间的数据变化 能够在Flink job任务中的算子函数中操做累加器,可是只能在任务执行结束以后才能得到累加器的最终结果。spark的累加器用法.javascript Flink中累加器的用法很是的简单:java 1:建立累加器:      val acc = new I
相关文章
相关标签/搜索