Hadoop 将变量从 reducer 传递到 main

Question

我正在研究 map 缩减程序。我正在尝试使用 setLong 方法将参数传递给 reduce 方法中的上下文配置，然后在完成后在 main 中读取它们

在 reducer 中:

context.getConfiguration().setLong(key, someLong);

在作业完成后的主要内容中，我尝试使用:

long val = job.getConfiguration().getLong(key, -1);

但我总是得到-1。

当我尝试读取 reducer 内部时，我看到值已设置并且我得到了正确的答案。

我错过了什么吗？

谢谢

Answer 1

您可以使用计数器:在 reducer 中设置和更新它们的值，然后您可以在您的客户端应用程序(主)中访问它们。