RecordReader 的概念
Concept of RecordReaders
我们知道在 Mapper 阶段之前，文件被拆分并且 RecordReader 开始工作以向 Mapper 发出输入。我的问题是 reducer 是否使用 RecordReader class 来读取 mapper 发出的数据？
因为 reducer 也需要输入！！
请解释！！！
mapreduce步骤概览如下
1) InputFormat :
- Validates the Input.
- Splits the input files.
- Gives Record Reader Implementation to give input to Mapper.
2)Mapper Phase
3)Shuffle and Sort Phase
4)Reducer Phase
5) OutputFormat
- Validates the Output Specification.
- Provides Record Writer Implementation used to write the output files.
Reducer 不使用记录 reader...
我们知道在 Mapper 阶段之前，文件被拆分并且 RecordReader 开始工作以向 Mapper 发出输入。我的问题是 reducer 是否使用 RecordReader class 来读取 mapper 发出的数据？
因为 reducer 也需要输入！！ 请解释！！！
mapreduce步骤概览如下
1) InputFormat :
- Validates the Input.
- Splits the input files.
- Gives Record Reader Implementation to give input to Mapper.
2)Mapper Phase
3)Shuffle and Sort Phase
4)Reducer Phase
5) OutputFormat
- Validates the Output Specification.
- Provides Record Writer Implementation used to write the output files.
Reducer 不使用记录 reader...