概览
在实现MapReduce的过程中,主要是实现一个MapReduce框架。这个框架是干嘛的呢?具体来说,就是使用者只需要定义自己的Map和Reduce方法,即可完成MapReduce功能。如下所示:
如下所示:
input is divided into "splits"
Input Map -> a,1 b,1 c,1
Input Map -> b,1
Input Map -> a,1 c,1
| | |
| -> Reduce -> c,2
-----> Reduce -> b,2