MapReduce 编程系列八根据输入路径产生输出路径和清除HDFS目录 - c++编程基础

TOP

MapReduce 编程系列八根据输入路径产生输出路径和清除HDFS目录(二)

2015-07-20 17:34:04 来源: 作者: 【大中小】浏览:6次

xt) throws IOException, InterruptedException { System.out.println("enter LogReducer:::cleanup method"); outputs.close(); } public void reduce(Text key, Iterable values, Context context) throws IOException, InterruptedException { System.out.println("enter LogReducer::reduce method"); int sum = 0; for (IntWritable val : values) { sum += val.get(); } System.out.println("key: " + key.toString() + " sum: " + sum); outputs.write("result", key, sum); } }
代码比之前的例子简单很多，仅仅是往一个named output "result" 写出结果。

首页上一页 1 2 下一页尾页 2/2/2
【大中小】【打印】【繁体】【投稿】【收藏】【推荐】【举报】【评论】【关闭】【返回顶部】
分享到:
上一篇：hdu 4412 Sky Soldiers(区间DP)	下一篇：Codeforces 86C Genetic engineer..

帐　　号:

密码: (新用户注册)

验证码:

表　　情:

内　　容: