com.aliyun.odps.counter

类 Counter

java.lang.Object

com.aliyun.odps.counter.Counter

所有已实现的接口:

Writable

public class Counter
extends Object
implements Writable

Counter计数器，可以自定义Counter，用于统计计数，例如统计脏数据记录个数.

Counter相关类的关系：

• Counters 是 CounterGroup 的集合
• CounterGroup 是 Counter 的集合

示例代码：

 public class UserDefinedCounterExample {
   enum MyCounter {
     DIRTY_RECORDS
   }

   public static class MyMapper extends Mapper<Text, Text> {
     Counter counter;

     protected void setup(MapContext<Text, LongWritable> context)
         throws IOException, InterruptedException {
       counter = context.getCounter(MyCounter.DIRTY_RECORDS);
     }

     public void map(LongWritable recordNum, Record record,
         MapContext<Text, Text> context) throws IOException,
         InterruptedException {
       if (dirty) {
         counter.increment(1);
       }
     }
   }

   public static void main(String[] args) throws Exception {
    JobConf job = new JobConf();
    ... ...
    RunningJob rJob = JobClient.runJob(job);
    Counters counters = rJob.getCounters();
    long count = counters.findCounter(MyCounter.DIRTY_RECORDS).getValue();
  }
 }
 

另请参阅:

Counters, CounterGroup, TaskAttemptContext#getCounter(Enum)

方法概要

方法

限定符和类型	方法和说明
boolean	equals(Object genericRight)
String	getDisplayName() 获取Counter的显示名称
String	getName() 获取Counter名称
long	getValue() 获取当前Counter计数值
int	hashCode()
void	increment(long incr) 增加Counter计数值
void	readFields(DataInput in) 从DataInput读取Counter信息
void	setValue(long value) 设置Counter计数值
void	write(DataOutput out) 写当前Counter到DataOutput

从类继承的方法 java.lang.Object

getClass, notify, notifyAll, toString, wait, wait, wait

方法详细资料

getName

public String getName()

获取Counter名称

返回:

Counter名称

getDisplayName

public String getDisplayName()

获取Counter的显示名称

返回:

Counter显示名称

getValue

public long getValue()

获取当前Counter计数值

返回:

当前Counter计数值

setValue

public void setValue(long value)

设置Counter计数值

参数:

value - Counter计数值

increment

public void increment(long incr)

增加Counter计数值

参数:

incr - Counter计数值的增量

equals

public boolean equals(Object genericRight)

覆盖:

equals 在类中 Object

hashCode

public int hashCode()

覆盖:

hashCode 在类中 Object

readFields

public void readFields(DataInput in)
                throws IOException

从DataInput读取Counter信息

指定者:

readFields 在接口中 Writable

抛出:

IOException

write

public void write(DataOutput out)
           throws IOException

写当前Counter到DataOutput

指定者:

write 在接口中 Writable

抛出:

IOException