我是hadoop的新手。我成功创建了一个自定义RecordReader和一个名为“Allineamento”的自定义类型,因此:

public class Allineamento extends Object implements WritableComparable<Allineamento>

map 阶段完成工作。当减少阶段开始时,我有这个exception:

有人建议我在“Allineamento”中插入一个空的构造函数(public Allineamento(){})。是这样吗又为什么呢

最佳答案

只需添加空的构造函数,显然Hadoop需要该类具有默认的构造函数,因此只需添加它。

public class Allineamento {
    public Allineamento() {

    }
}

它应该工作。

关于java - Hadoop Mapreduce自定义RecordReader减少阶段,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/17529076/

10-09 05:20