hsdoop序列化示例

Hadoop序列化是将数据结构转换为字节流，以便在Hadoop集群中进行传输和存储。下面是一个简单的Hadoop序列化示例：

假设有一个Person类，该类具有以下属性和方法：

public class Person implements Writable {
    private String name;
    private int age;

    public Person() {}

    public Person(String name, int age) {
        this.name = name;
        this.age = age;
    }

    public void write(DataOutput out) throws IOException {
        out.writeUTF(name);
        out.writeInt(age);
    }

    public void readFields(DataInput in) throws IOException {
        name = in.readUTF();
        age = in.readInt();
    }
}

在上述示例中，Person类实现了Writable接口，并覆盖了write和readFields方法。write方法将Person对象的属性写入DataOutput流中，而readFields方法从DataInput流中读取属性。

现在，我们可以使用以下代码将Person对象进行序列化：

Person person = new Person("John", 25);

ByteArrayOutputStream outStream = new ByteArrayOutputStream();
DataOutputStream dataOutStream = new DataOutputStream(outStream);

person.write(dataOutStream);

byte[] serializedPerson = outStream.toByteArray();

在上述代码中，我们首先创建一个Person对象，然后创建一个ByteArrayOutputStream和一个DataOutputStream。我们将Person对象写入DataOutputStream中，然后使用toByteArray方法将其转换为字节数组。

现在，我们可以使用以下代码将Person对象进行反序列化：

Person deserializedPerson = new Person();

ByteArrayInputStream inStream = new ByteArrayInputStream(serializedPerson);
DataInputStream dataInStream = new DataInputStream(inStream);

deserializedPerson.readFields(dataInStream);

在上述代码中，我们首先创建一个新的Person对象，然后创建一个ByteArrayInputStream和一个DataInputStream。我们从字节数组中读取数据，并将其存储在deserializedPerson对象中。

这就是一个简单的Hadoop序列化示例！