使用MultipleInputs.addInputPath 对多个路径输入
如今如果有三个文件夹,并使用了三个mapper去处理,
经过map处理后,输出的结果会依据key 进行join,
假设使用TextPair,会依据第一个字段jion。第二个字段排序
然后在作为reduce的输入,进行计算
时间: 2024-12-20 11:09:14
使用MultipleInputs.addInputPath 对多个路径输入
如今如果有三个文件夹,并使用了三个mapper去处理,
经过map处理后,输出的结果会依据key 进行join,
假设使用TextPair,会依据第一个字段jion。第二个字段排序
然后在作为reduce的输入,进行计算