inputvalue不赞成用什么来代替mrunit

d8tt03nd  于 2021-06-03  发布在  Hadoop
关注(0)|答案(1)|浏览(411)

我使用mrunit测试map reduce代码。我不能使用.withinputvalue,因为它已被弃用。我找不到一个有效的等价物。setinputvalue也不起作用。你的工作是什么?

mwg9r5ms

mwg9r5ms1#

使用 withInput() . exmaple(这个。使用mrunit-1.0.0-hadoop2.jar)

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>

有关详细信息,请参见教程

相关问题