MapReduce工作流程详解

MapReduce工作流程 1.由程序内的InputFormat(默认实现类TextInputFormat)来读取外部数据，它会调用RecordReader(它的成员变量)的read()方法来读取，返回k,v键值对。 2.读取的k,v键值对传送给map()方法，作为其入参来执行用户定义的map逻辑。 3.context.write方法被调用时，outputCollector组件会将map()方法的

>>阅读原文<<