java - 将对象写入hadoop hdfs问题

Question

我正在尝试将对象写入hdfs。

Split currentsplit = new Split();
Path p = new Path("C45/mysavedobject");
ObjectOutputStream oos = new ObjectOutputStream(fs.create(p));
oos.writeObject(currentsplit);
oos.close();

但是我无法获得确切的对象值。

Path p = new Path("C45/mysavedobject");
Split curntsplit = null;
ObjectInputStream ois = new ObjectInputStream(fs.open(p));
try {
    curntsplit = (Split) ois.readObject();
} catch (ClassNotFoundException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
}
 ois.close();

显示重复的对象值。

在驱动程序中，我得到:

objjjjjjj in driver pck.Split@14da173c

将对象写入文件并在驱动程序本身中进行读回之后，我得到了备用的对象值。

objjjjjj in mysavedobject pck.Split@62eade0

我希望驱动程序对象符合我的Mapper代码。

为什么会这样呢？

Answer 1

您的自定义拆分对象(pck.Split)没有定义toString方法，因此您看到的是类名，后跟一个内存中的地址(因为Java没有其他方式向您显示该对象的字符串值) 。

只需将toString方法实现添加到自定义的Split类中并重新运行-现在您应该能够确认读写对象是否具有相同的内容。