MapReduce工作机制详解
2020-04-17 16:56:26 0 举报
MapReduce工作机制详解
作者其他创作
大纲/内容
最终输出的结果文件分区且排序
溢出组件
20%
RecordReader(抽象类)
InputFormat
MapOutputCollect
调用组件
/wordCount/output/part-r-0000
WordCountReducer
MapReduce工作机制详解
partition0
key:行偏移量value:行内容
ReduceTask2
读取数据
ReduceTask1
partition2
partition1
split0
环型缓冲区默认100M
MrAppMaster
有序的文件,并且都是partition0的数据
溢出比80%
split1
有序的文件,并且都是partition2的数据
WordCountMapper
RecordWriter(抽象类)默认实现:TextRecordReader
有序的文件,并且都是partition1的数据
OutPutFormat
分区partition溢出到磁盘文件,分区且排序
Spiller
+ spill()
MapTask
HDFS
自己去maptask上的输出结果文件中拉取属于自己分区(分区0)的数(http下载)据
RecordReader(抽象类)默认实现:LIneRecordReader
split2
ReduceTask0
指挥reduceTask到哪个maptask获取数据
0 条评论
下一页