Hadoop学习–person类对象的序列化和反序列化–day07

person类的代码：

import java.io.DataInput;

import java.io.DataOutput;

import java.io.IOException;

import org.apache.hadoop.io.BooleanWritable;

import org.apache.hadoop.io.IntWritable;

import org.apache.hadoop.io.Text;

import org.apache.hadoop.io.Writable;

public class Person implements Writable {

//相当于String类型

private Text name;

public Text getName() {

return name;

}

public void setName(Text name) {

this.name = name;

}

public IntWritable getAge() {

return age;

}

public void setAge(IntWritable age) {

this.age = age;

}

public BooleanWritable getMale() {

return male;

}

public void setMale(BooleanWritable male) {

this.male = male;

}

private IntWritable age;

private BooleanWritable male;

//序列化

public void write(DataOutput out) throws IOException{

name.write(out);

age.write(out);

male.write(out);

}

//反序列化

public void readFields(DataInput in) throws IOException{

name = new Text();

age=new IntWritable();

male=new BooleanWritable();

name.readFields(in);

age.readFields(in);

male.readFields(in);

}

}

测试类的代码：

import java.io.ByteArrayInputStream;

import java.io.ByteArrayOutputStream;

import java.io.DataInputStream;

import java.io.DataOutputStream;

import org.apache.hadoop.io.BooleanWritable;

import org.apache.hadoop.io.IntWritable;

import org.apache.hadoop.io.Text;

import org.junit.Test;

public class TestPerson {

  @Test

  public void testSeria() throws Exception{

 //new person

 Person p = new Person();

 p.setName(new Text(“tomas”));

 p.setAge(new IntWritable(12));

 p.setMale(new BooleanWritable(false));

 //序列化

 ByteArrayOutputStream baos = new ByteArrayOutputStream();

 DataOutputStream dataOut = new DataOutputStream(baos);

 p.write(dataOut);

 dataOut.close();

 //反序列化

 Person newPerson = new Person();

 newPerson.readFields(new DataInputStream(new ByteArrayInputStream(baos.toByteArray())));

 System.out.println(newPerson.getName());

 System.out.println(newPerson.getAge().get());

 

 

  }

}