我一直在搜索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
谢谢
最佳答案
Configuration conf = new Configuration();
conf.set("delimiter", someValue);
myMapDriver.withConfiguration(conf);
关于hadoop - 在mrunit中设置配置,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/19612777/