hadoop如何从mapper获得工作

nimxete2  于 2021-06-03  发布在  Hadoop
关注(0)|答案(2)|浏览(226)

我是hadoop新手。这次我实现了输入关键字的单词计数器。我也用 Job 班级比 JobConf . 我有一个主类的代码:

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

那么我怎样才能得到我的关键字呢 Mapper 回来?据我所知,我需要 Job 对象和源 Job 得到 Configuration 对象使用 getConfiguration() 方法和than调用 get("keyword") 方法。
但我需要怎样才能 JobMapper 上课?
谢谢你的时间。

xghobddn

xghobddn1#

用于在conf中设置参数的代码看起来不错。
在mapper函数中,您需要执行以下操作:

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

jq6vz3qz2#

在mapper实现上调用map时,会传递一个上下文对象,该对象公开getconfiguration方法。这会给你想要的。

相关问题