我需要关于地图缩减链的帮助。我有一个类似的地图缩减链
映射->减少->映射
我想在最后一个映射中使用reducer的输出
例如,在我的reducer中,我得到的是一名员工的最高工资,这个值应该在下一个映射器中使用,并找到具有该最高工资值的记录。所以很明显,我的最后一个映射程序应该得到reducer的输出和文件的内容?有可能吗?我该如何解决这个问题?有更好的解决方案吗?
我不确定我是否理解这个问题,但我会尽力提供帮助
您已经将一些包含员工工资的输入(称为input1)减少为输出(称为output1),如下所示:
CCD_ 1。
现在您想要另一个映射器来映射来自input1和output1的数据
如果是这样的话,你可以根据自己的需要选择一个。
-
操纵第一个减速器输出。创建格式为
Key: someEmployee Value: max_salary@@salary_1,salary_2,salary_3...salary_n
的输出1的instad然后创建新作业,并将新映射器输入设置为output1。 -
试着阅读这个问题,解释如何将多个输入输入到一个映射器