hadoop - MapReduce 中的多个输入路径错误

Question

我正在 Eclipse 中编写多输入 Mapreduce 程序，下面是代码行的一部分

代码：

Path map1=new Path(args[0]);
Path map2=new Path(args[1]);

MultipleInputs.**addInputPath**(job,map1, TextInputFormat.class,Mapper1.class);
MultipleInputs.**addInputPath**(job,map2, TextInputFormat.class,Mapper2.class);

在“addInputpath”中，我收到如下错误，

错误：MultipleInputs 类型中的方法 addInputPath(Job, Path, Class, Class) 不适用于参数 (Job, Path, Class, Class)

有人可以帮忙吗？

请在下面的链接中找到代码

https://www.dropbox.com/s/fm3m0ed4gh6jy98/代码

问候，维什瓦

Answer 1

我能说的是你错误地导入了一个不兼容的，

import org.apache.hadoop.mapred.TextInputFormat;

应该是，

import org.apache.hadoop.mapreduce.lib.input.TextInputFormat;

Hadoop 提供了两个 API 来创建作业，一个属于 org.apache.hadoop.mapred，另一个属于 org.apache.hadoop.mapreduce。我认为您正在使用后者，这是您应该导入的。