java - Hadoop Map Reduce CustomRecordReader

Question

我按照本指南为 hadoop 创建了一个自定义输入拆分。现在我每次都有一个例外：

FileSplit split = (FileSplit) genericSplit;

我导入了这个 2：

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

但我不明白为什么要给我例外。FileSplit扩展了InputSplit，那么为什么会有例外呢？

Answer 1

我想你想要

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

并不是

import org.apache.hadoop.mapred.FileSplit;

或者，至少，您似乎在混合使用这两个不同的类（o.a.h.mapreduce.lib.input.FileSplitvs o.a.h.mapred.FileSplit）。仔细阅读您的异常消息。