InputFormat
将输出文件拆分为多个 InputSplit
,并由 RecordReaders
将 InputSplit
转换为标准的map
提供输入,以便进行并行处理。
combiner
是 map
运算后的可选操作,它实际上是一个本地化的 reduce
操作,它主要是在 map
计算出中间文件后做一个简单的合并重复 key
值的操作。这里以词频统计为例:
map
在遇到一个 hadoop 的单词时就会记录为 1,但是这篇文章里 hadoop 可能会出现 n 多次,那么 map
输出文件冗余就会很多,因此在 reduce
计算前对相同的 key 做一个合并操作,那么需要传输的数据量就会减少,传输效率就可以得到提升。
但并非所有场景都适合使用 combiner
&