在mrunit中設置配置

Question

我一直在尋找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

感謝

Answer 1

使用MapDriver.withConfiguration

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

Answer 2

我有類似的問題，我解決它下面的代碼給出英寸

mapDriver.withInput(key, value); 
mapDriver.getConfiguration().set("my.config.param", "my.config.param.value"); 
..... 
..... 
mapDriver.run(); 

請注意，mapDriver.getContext（）。getConfiguration可能無法在這種情況下工作，因爲上下文對象是在API中嘲笑的對象。