Flink 累加器 实例

本文主要是介绍Flink 累加器 实例，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

每个并行的任务实例下有各自的累加器，获取最终值时会把各个并行任务的累加器的值求和。（一个并行度对应一个累加器）

版本: flink1.9.2    java1.8

map并行度1:

package Counter;import org.apache.flink.api.common.JobExecutionResult;
import org.apache.flink.api.common.accumulators.IntCounter;
import org.apache.flink.api.common.functions.RichMapFunction;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;/*** @Author you guess* @Date 2020/6/25 12:30* @Version 1.0* @Desc*/
public class CounterTest1 {public static void main(String[] args) throws Exception {//获取执行环境final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();//数据来源DataStream<String> source1 = env.fromElements("a", "b&#

这篇关于Flink 累加器 实例的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---