0

このガイドに従って、hadoop 用のカスタム入力分割を作成しました。今、私はこれについて毎回例外があります:

FileSplit split = (FileSplit) genericSplit;

私はこれをインポートしました 2:

import org.apache.hadoop.mapred.FileSplit;
import org.apache.hadoop.mapreduce.InputSplit;

しかし、なぜ私に例外を与えるのかわかりません。FileSplitを拡張しますがInputSplit、なぜ例外なのでしょうか?

4

1 に答える 1

2

私はあなたが欲しいと思います

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

そしてそうではない

import org.apache.hadoop.mapred.FileSplit;

または、少なくとも、これら 2 つの異なるクラス ( o.a.h.mapreduce.lib.input.FileSplitvs o.a.h.mapred.FileSplit) の使用を混在させているようです。例外メッセージを注意深く読んでください。

于 2013-07-07T18:22:41.140 に答える