分享

请教求平均分数问题?

xdw076 发表于 2015-8-13 17:45:12 [显示全部楼层] 回帖奖励 阅读模式 关闭右栏 1 7652
版本: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));
        }

并且没有打印输出,是什么原因?求教大神

已有(1)人评论

跳转到指定楼层
arsenduan 发表于 2015-8-13 17:59:24
本帖最后由 arsenduan 于 2015-8-13 18:15 编辑



// process values
                System.out.println("------------------key...."+key);
                System.out.println("-------------------values..."+values);
               
替换为
  context.write(“-------------------values...”,"+values");
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

推荐上一条 /2 下一条