版本:hadoop 2.6
学习网上教程时,求平均分数,输出结果:
张三 78
张三 88
张三 80
李四 82
李四 89
李四 99
王五 66
王五 84
王五 96
赵六 67
赵六 86
赵六 77
reduce中代码:
public void reduce(Text key, Iterable<IntWritable> values, Context context) throws IOException, InterruptedException {
// process values
System.out.println("------------------key...."+key);
System.out.println("-------------------values..."+values);
int sum = 0;
int count = 0;
Iterator<IntWritable> iterator = values.iterator();
while (iterator.hasNext()) {
sum += iterator.next().get();
count++;
}
int average = (int) sum / count;
context.write(key, new IntWritable(average));
}
并且没有打印输出,是什么原因?求教大神 |
|