我一直在搜索mrunit文档,但到目前为止仍无法找到它。
我如何在我的mrunit中传递配置参数。

因此,例如,如果我以wordcount为例。

可以说,在我的驱动程序代码中,我正在设置此参数...

conf.set("delimiter",args[2])

在我的映射器代码中,我将此称为:
String delimiter = conf.get("delimiter");
String [] tokens = value.toString().split(delimiter);
for (String token:tokens)
   context.write(token,one);

如何设置此配置参数。

我一直在研究这个例子:
https://github.com/wpm/Hadoop-Word-Count/blob/master/src/test/java/wpmcn/hadoop/WordCountTest.java

谢谢

最佳答案

使用MapDriver.withConfiguration

 Configuration conf = new Configuration();
 conf.set("delimiter", someValue);
 myMapDriver.withConfiguration(conf);

关于hadoop - 在mrunit中设置配置,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/19612777/

10-16 23:52