Hadoop、Spark计数器(累加器)使用

1. MapReduce中自定义计数器(枚举方式) 1.1 首先定义并使用计数器 //第一种 组名+计数器名 context.getCounter(groupName, counterName).increment(1);//参数类型为String //第二种 Enum context.getCounter(counterName).increment(1);//参数类型为Enum //使用,
相关文章
相关标签/搜索