我使用mrunit测试map reduce代码。我不能使用.withinputvalue,因为它已被弃用。我找不到一个有效的等价物。setinputvalue也不起作用。你的工作是什么?
mwg9r5ms1#
使用 withInput() . exmaple(这个。使用mrunit-1.0.0-hadoop2.jar)
withInput()
MapDriver<LongWritable,Text,Text,IntWritable> mapDriver; ... mapDriver.withInput(new LongWritable(), new Text("some line of text)); mapDriver.withOUtput(new Text("some key)); new IntWritable(..)); mapDriver.runTest();
这是maven依赖关系。注意hadoop2分类器。
<dependency> <groupId>org.apache.mrunit</groupId> <artifactId>mrunit</artifactId> <version>1.0.0</version> <classifier>hadoop2</classifier> </dependency>
有关详细信息,请参见教程
1条答案
按热度按时间mwg9r5ms1#
使用
withInput()
. exmaple(这个。使用mrunit-1.0.0-hadoop2.jar)这是maven依赖关系。注意hadoop2分类器。
有关详细信息,请参见教程