このガイドに従って、hadoop 用のカスタム入力分割を作成しました。今、私はこれについて毎回例外があります:
FileSplit split = (FileSplit) genericSplit;
私はこれをインポートしました 2:
import org.apache.hadoop.mapred.FileSplit;
import org.apache.hadoop.mapreduce.InputSplit;
しかし、なぜ私に例外を与えるのかわかりません。FileSplit
を拡張しますがInputSplit
、なぜ例外なのでしょうか?