映射中的输入/输出流减少了链接



我需要关于地图缩减链的帮助。我有一个类似的地图缩减链

映射->减少->映射

我想在最后一个映射中使用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。

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

相关内容

  • 没有找到相关文章

最新更新