我是hadoop新手。我成功创建了一个自定义 RecordReader 和一个名为“Allineamento”的自定义类型,因此:
public class Allineamento extends Object implements WritableComparable<Allineamento>
map 阶段工作并完成他的工作。当减少阶段开始时,我有这个 exception :
有人建议我在“Allineamento”中插入一个空构造函数(public Allineamento(){})。是这样吗?为什么?
最佳答案
只需添加空构造函数,显然Hadoop需要该类有一个默认构造函数,所以只需添加它即可。
public class Allineamento {
public Allineamento() {
}
}
它应该可以工作。
关于java - Hadoop MapReduceCustomRecordReaderReduce阶段,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/17529076/