api - Hadoop Mapreduce 配置（新 API）

Question

我只是想尝试一个教程（https://ccp.cloudera.com/display/DOC/Hadoop+Tutorial）程序WordCount V.2（页面底部），其中他们使用以下方法设置一些基本程序变量：

public void configure(JobConf job) {
...
}

但是我正在尝试使用新的 Hadoop API，但这种方法似乎不再存在？谁能告诉我在新 API 中做这种事情的等效方法是什么？

另外，如何在运行时访问我的配置？我是否简单地调用：

Job.getConfiguration();

score 2 · Accepted Answer

您可以覆盖Mapper/中的设置方法Reducer，这将表现得像configure.

签名如下所示：

 @Override
 protected void setup(Context context) throws IOException,
       InterruptedException {

在那里你得到一个Context对象，你可以在其中调用：

Configuration conf = context.getConfiguration();

map并且cleanup，两者都有这些上下文对象，因此您可以Configuration随时获取。

1 回答 1