0

私は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/コード

よろしく、ヴィシュワ

4

1 に答える 1

0

私が言えることは、互換性のないものを間違ってインポートしたということです。

import org.apache.hadoop.mapred.TextInputFormat;

あるべきだった、

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

Hadoop は、ジョブを作成するための 2 つの API を提供します。1 つは org.apache.hadoop.mapred に属し、もう 1 つは org.apache.hadoop.mapreduce に属します。後者を使用していると思いますが、それをインポートする必要があります。

于 2013-07-24T06:47:42.870 に答える