flink-13 Flink之Counter（计数器/累加器）_flink counter

作者：很楠不爱3 | 2024-06-09 23:11:44

踩

flink counter

Flink之Counter

概念
用法
示例

概念

Accumulator即累加器，与Mapreduce counter的应用场景差不多，都能很好地观察task在运行期间的数据变化，可以在Flink job任务中的算子函数中操作累加器，但是只能在任务执行结束之后才能获得累加器的最终结果。
Counter是一个具体的累加器(Accumulator)实现IntCounter, LongCounter 和 DoubleCounter

用法

1.创建累加器
private IntCounter numLines = new IntCounter(); 

2.注册累加器
getRuntimeContext().addAccumulator("num-lines", this.numLines);

3.使用累加器
this.numLines.add(1); 

4.获取累加器的结果
myJobExecutionResult.getAccumulatorResult("num-lines")
1
2
3
4
5
6
7
8
9
10
11

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/很楠不爱3/article/detail/696166