Hadoop序列化与反序列化具体实践

首先创建两个类
两个类的代码
Student类：

1. import org.apache.hadoop.io.Writable;
3. import java.io.DataInput;
4. import java.io.DataOutput;
5. import java.io.IOException;
7. public class Student implements Writable {
8.     public Student(String name, int age) {
9.         this.name = name;
10.         this.age = age;
11.     }
13.     public Student() {
14.     }
16.     public String name;
17.     public int age;
19.     @Override
20.     public void write(DataOutput dataOutput) throws IOException {
21.         dataOutput.writeUTF(name);
22.         dataOutput.writeInt(age);
23.     }
25.     @Override
26.     public void readFields(DataInput dataInput) throws IOException {
27.         name = dataInput.readUTF();
28.         age = dataInput.readInt();
29.     }
30. }

复制代码

TestStudent类：

1. import java.io.*;
3. public class TestStudent {
4.     public static void main(String[] args) throws IOException, ClassNotFoundException {
5.         Student student = new Student("小花", 18);
7.         // hadoop序列化
8.         DataOutputStream dos = new DataOutputStream(new FileOutputStream("Student_hadoop.txt"));
9.         student.write(dos);
11.         // hadoop 反序列化
12.         DataInputStream dis = new DataInputStream(new FileInputStream("Student_hadoop.txt"));
13.         Student student1 = new Student();
14.         student1.readFields(dis);
15.         System.out.println(student1.name+ " "+student1.age);
16.     }
17. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。