java - Hadoop。如何从 Mapper 获得工作

Question

我是 Hadoop 的新手。这次我实现了输入关键字的单词计数器。我也读到了使用Jobclass 比JobConf. 所以我有这个主类的代码：

...
Configuration conf = new Configuration();
conf.set("keyword", args[0]);
Job job = new Job(conf);
...

那么我怎样才能让我的关键字Mapper回来呢？据我了解，我需要使用方法而不是调用方法来获取我的Job对象和Job获取对象。ConfigurationgetConfiguration()get("keyword")

Job但是我需要如何Mapper上课？

谢谢你的时间。

Answer 1

当在 Mapper 实现上调用 map 时，它会传递一个 Context 对象，该对象公开一个 getConfiguration 方法。这会给你你想要的。

Answer 2

您用来在 conf 中设置参数的代码看起来没问题。

在 mapper 函数中，您需要执行以下操作：

Configuration conf = context.getConfiguration();
String keyword = conf.get("keyword");