mapTask和ReduceTask工作机制以及mapreduce完整流程

1、mapTask工作机制() 1、Read阶段:mapTask通过用户编写的RecordReader,从输入InputSplit中解析出一个个key/value对; 2、Map阶段:该节点主要是将解析出的key、value(k1,v2)交给用户编写map()函数处理,并产生一系列新的key、value对(k2,v2); 3、Collect收集阶段:在用户编写map()函数中,当数据处理完成后,一
相关文章
相关标签/搜索