我是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")
方法。
但我需要怎样才能 Job
从 Mapper
上课?
谢谢你的时间。
2条答案
按热度按时间xghobddn1#
用于在conf中设置参数的代码看起来不错。
在mapper函数中,您需要执行以下操作:
jq6vz3qz2#
在mapper实现上调用map时,会传递一个上下文对象,该对象公开getconfiguration方法。这会给你想要的。