我关注了this为 hadoop 创建自定义输入拆分的指南。现在我每次都有一个异常(exception):
FileSplit split = (FileSplit) genericSplit;
我导入了这 2 个:
import org.apache.hadoop.mapred.FileSplit;
import org.apache.hadoop.mapreduce.InputSplit;
但我不明白为什么给我异常(exception)。 FileSplit 扩展了 InputSplit，那么为什么会有异常？
最佳答案
我觉得你想要
import org.apache.hadoop.mapreduce.lib.input.FileSplit;
不是
import org.apache.hadoop.mapred.FileSplit;
或者，至少，您似乎混合使用了这两个不同 类(o.a.h.mapreduce.lib.input.FileSplit 与o.a.h.mapred.FileSplit)。仔细阅读您的异常消息。
关于java - Hadoop Mapreduce 自定义记录读取器，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/17514870/