分析

Hadoop为每个作业维护若干内置计数器,以描述多项指标.

API

  1. 采用枚举的方式统计计数
  1. enum MyCounter{MALFORORMED, NORMAL}
  3. //对枚举定义的自定义计数器加1
  4. context.getCounter(MyCounter.MALFORORMED).increment(1);
  1. 采用计数器组,计数器名称的方式统计
  1. context.getCounter("counterGroup", "countera").increment(1);

组名和计数器名称随便起,但最好有意义

计数器结果在程序运行后的控制台上查看

代码

image.png

这个统计是全局的