有没有一种方法可以将一个整数值从mapper类传递给所有的reducer

wlsrxk51  于 2021-06-04  发布在  Hadoop
关注(0)|答案(1)|浏览(320)

我想把这个整数值像a=100一样传递给所有的减速机。然后在reduce函数中,我可以使用这个值。有办法吗?我不想把这个值像<“a”,100>那样配对,因为它会转到一个我不知道的特定的减速机,在这种情况下,不是所有的减速机都会收到这个值。
每个减速器都需要该值。

7kqas0il

7kqas0il1#

您应该能够通过jobconf对象传递它。将configure中获得的jobconf分配给本地示例并设置值。应该在reducer的configure()中可用。

相关问题