Mapreduce过程详解(图解+注解)

MapReduce一共分为map和reduce两个阶段 (1234)map task流程是通过TextInputFormat->RecordReadeer->read()一次读一行,返回到(key,value) (5)获取(key,value)单行数据,进行数据分割,生成新的(key,value),通过context.write()把新的(key,value)输出到OutpuCollector收集
相关文章
相关标签/搜索