mapreduce运行机制详解

一个MapTask对应一个切片 切片的计算: long splitSize = Math.max(minSize, Math.min(maxSize, blockSize)) 默认:minSize 1 maxSize Long.MAX_VALUE blockSize 128 splitSize默认是128M。 FileInputFormat先扫描切片,每次扫描一行数据,调用RecordReader
相关文章
相关标签/搜索