码迷,mamicode.com
首页 > 其他好文 > 详细

Hadoop学习第七次:MapReduce简介

时间:2014-12-12 22:02:04      阅读:186      评论:0      收藏:0      [点我收藏+]

标签:style   blog   http   color   sp   文件   数据   2014   log   

MapReduce是一种分布式计算模型。由Map和reduce两个阶段组成,用户只需要实现Map()和Reduce()两个函数即可实现分布式计算。这两个函数的形参是key,value对,表示函数的输入信息。

bubuko.com,布布扣

bubuko.com,布布扣

执行步骤:

 1. map任务处理

1.1 读取输入文件内容,解析成key、value对。对输入文件的每一行,解析成key、value对。每一个键值对调用一次map函数。

1.2 写自己的逻辑,对输入的key、value处理,转换成新的key、value输出。

1.3 对输出的key、value进行分区。

1.4 对不同分区的数据,按照key进行排序、分组。相同key的value放到一个集合中。

1.5 (可选)分组后的数据进行归约。

2.reduce任务处理

2.1 对多个map任务的输出,按照不同的分区,通过网络copy到不同的reduce节点。

2.2 对多个map任务的输出进行合并、排序。写reduce函数自己的逻辑,对输入的key、value处理,转换成新的key、value输出。

2.3 把reduce的输出保存到文件中。

例子:实现WordCountApp

Hadoop学习第七次:MapReduce简介

标签:style   blog   http   color   sp   文件   数据   2014   log   

原文地址:http://www.cnblogs.com/carol19910211/p/4160478.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!