我需要帮助有关Map减少链。我有一个Map减少链这样Map->缩小->Map我想在最后一个Map器中使用reducer的输出例如，在我的reducer中，我得到一个雇员的最大工资，这个值应该在下一个Map器中使用，并找到具有该最大工资值的记录。所以很明显，我的上一个Map器应该得到reducer的输出和文件的内容？可能吗？我如何解决问题？有更好的解决方案吗？
x8goxv8g1#
我不确定我是否理解这个问题，但我会尽力帮助你的。您已经将一些包含员工工资的输入（我们称之为input1）减少为输出（我们称之为output1），如下所示： Key: someEmployee Value: max salary .现在您想让另一个Map器Mapinput1和output1的数据吗？如果是这样的话，你就没有多少选择了，你可以根据自己的需要选择一个。操纵第一个减速器输出。按以下格式创建output1的步骤 Key: someEmployee Value: max_salary@@salary_1,salary_2,salary_3...salary_n 然后创建新作业，并将新Map器输入设置为output1。尝试阅读本期文章，解释如何将多个输入输入到一个Map器中
Key: someEmployee Value: max salary
Key: someEmployee Value: max_salary@@salary_1,salary_2,salary_3...salary_n
1条答案
按热度按时间x8goxv8g1#
我不确定我是否理解这个问题，但我会尽力帮助你的。
您已经将一些包含员工工资的输入（我们称之为input1）减少为输出（我们称之为output1），如下所示：
Key: someEmployee Value: max salary.现在您想让另一个Map器Mapinput1和output1的数据吗？
如果是这样的话，你就没有多少选择了，你可以根据自己的需要选择一个。
操纵第一个减速器输出。按以下格式创建output1的步骤
Key: someEmployee Value: max_salary@@salary_1,salary_2,salary_3...salary_n然后创建新作业，并将新Map器输入设置为output1。尝试阅读本期文章，解释如何将多个输入输入到一个Map器中