0

我需要有关 map reduce 链接的帮助。我有一个这样的 map reduce 链

映射->减少->映射

我希望在最后一个映射器中使用减速器的输出

例如,在我的减速器中,我得到了员工的最高工资,这个值应该在下一个映射器中使用,并找到具有该最大工资值的记录。所以显然我的最后一个映射器应该得到减速器的输出和文件的内容?有可能吗?我该如何解决这个问题?有更好的解决方案吗?

4

1 回答 1

0

我不确定我是否理解这个问题,但我会尽力提供帮助。
您已将一些包含员工工资的输入(我们称之为 input1)减少为输出(我们称之为 output1),如下所示:
Key: someEmployee Value: max salary.
现在您想要另一个映射器来映射来自 input1 和 output1 的数据?
如果是这样,那么您的选择很少,您可以根据自己的需要选择一个。

  • 操纵第一个减速器输出。以格式创建 output1,
    Key: someEmployee Value: max_salary@@salary_1,salary_2,salary_3...salary_n
    然后创建新作业,并将新的映射器输入设置为 output1。

  • 尝试阅读这个问题,解释如何将多个输入输入到一个映射器中

于 2013-08-19T10:56:27.577 回答