0

Hadoop の StreamInputFormat を使用して xml ファイルを処理しようとしています。そして、私はこれに新しい API (Hadoop-0.20.205.0) を使用しています。示しています -

"The method setInputFormatClass(Class<? extends InputFormat>) in the type Job is not pplicable for the arguments (Class<StreamInputFormat>)"

「hadoop-streaming-0.20.205.0.jar」を明示的にダウンロードし、「org.apache.hadoop.streaming」パッケージをインポートしましたが、まだうまくいきません。

4

1 に答える 1

1

新しい API クライアント ジョブ (mapreduce) で古い API の InputFormat (mapred) を使用しようとしています。

Job.setInputFormat()は拡張するクラスo.a.h.mapreduce.InputFormat(新しい 'mapreduce' API) を期待していますが、ストリーミング API はすべて古い API ('mapred' パッケージ) で記述されているため、StreamInputFormatextendso.a.h.mapred.KeyValueTextInputFormatが次に拡張しますo.a.h.mapred.FileInputFormat(どちらも古い API です):

于 2012-06-19T16:56:17.320 に答える