hadoop - 用什么代替 mrunit withInputValue deprecated

Question

我正在使用 MRUnit 来测试 Map Reduce 代码。我不能使用 .withInputValue ，因为它已被弃用。我找不到有效的等价物。setInputValue 也不起作用。解决方法是什么？

Answer 1

使用withInput(). 示例（这个。与 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>

有关详细信息，请参阅教程