java - Hadoop Mapreduce自定义RecordReader

我遵循this指南为hadoop创建了一个自定义输入拆分。现在我每次都有一个异常(exception):

FileSplit split = (FileSplit) genericSplit;

我导入了这个2:

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

但我不明白为什么要给我异常(exception)。 FileSplit扩展了InputSplit，那么为什么要异常(exception)呢？

最佳答案

我想你要

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自定义RecordReader，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/17514870/