MapReduce是分布式、并行、离线的计算框架
Wordcount框架搭建(自己实现一个)
到此大概框架就是这样了。接下来就是实现此框架
一行数据执行一次map方法
对应reduce的输入阶段如下:
map阶段找到map,reduce阶段找到reduce。
接下来就是进行测试
无论map还是reduce都是要有输出