6)Hadoop之MapReduce(MapTask、ReduceTask工作机制)

MapTask工作机制: Read阶段: MapTask通过用户编写的RecorderReader,从输入的InputSplit中解析出一个个的key/vale; Map阶段: 该阶段主要是将解析出的key/value交给用户编写的map()方法处理,并产生一系列新的key/value; Collect收集阶段: 结束map()方法中的数据处理后,一般会调用OutputCollector.coll
相关文章
相关标签/搜索