我想把这个整数值像a=100一样传递给所有的减速机。然后在reduce函数中,我可以使用这个值。有办法吗?我不想把这个值像<“a”,100>那样配对,因为它会转到一个我不知道的特定的减速机,在这种情况下,不是所有的减速机都会收到这个值。每个减速器都需要该值。
7kqas0il1#
您应该能够通过jobconf对象传递它。将configure中获得的jobconf分配给本地示例并设置值。应该在reducer的configure()中可用。
1条答案
按热度按时间7kqas0il1#
您应该能够通过jobconf对象传递它。将configure中获得的jobconf分配给本地示例并设置值。应该在reducer的configure()中可用。