hadoop,map里reporter.getCounter("aa","total").increment(1);,reduce怎么获取到

qing里 发布于 2015/08/19 09:09
阅读 141
收藏 0
public void map(LongWritable key, Text value,OutputCollector<IntWritable, Text> output, Reporter reporter)
throws IOException {
reporter.getCounter("aa","total").increment(1);

}

public void reduce(IntWritable key, Iterator<Text> values,
OutputCollector<NullWritable, Text> output, Reporter reporter)
throws IOException {

}
加载中
0
尚浩宇
尚浩宇
你的意思是map里的数据怎么传递到reduce里?
尚浩宇
尚浩宇
回复 @123大时代 : 方法外应该有个枚举吧?然后context.getCounter(Counter.TIMER),评论里不好写代码,你看看我这个文章http://my.oschina.net/shyloveliyi/blog/423332,不是针对计数器的,不过里面有用,你可以看看,希望对你有帮助
1
123大时代
不是,我知道map的数据怎么传,现在想在reduce获取到map计数器的信息,counter是一个计数器
返回顶部
顶部