MapReduce中的多输入路径出错



我正在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/Code

谨致问候,vishwa

我能告诉你的是,你错误地导入了一个不兼容的

import org.apache.hadoop.mapred.TextInputFormat;

应该是

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

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

相关内容

  • 没有找到相关文章

最新更新