Hadoop学习,int类型的序列化和反序列化——day07

进口java.io.ByteArrayInputStream;

进口java.io.ByteArrayOutputStream;

进口java.io.DataInputStream;

进口java.io.DataOutputStream;

进口org.apache.hadoop.io.IntWritable;

进口org.apache.hadoop.io.ShortWritable;

进口org.junit.Test;

公共类TestWritable {

/* *测试可写的

*/

@Test

公共空间test1()抛出异常{

IntWritable年龄=new IntWritable ();

age.set (163),

ByteArrayOutputStream包=new ByteArrayOutputStream ();

DataOutputStream dataOut=new DataOutputStream(包);

//序列化

age.write (dataOut);

dataOut.close ();

bts byte []=baos.toByteArray ();

(字节:bts) {

System.out.println(通过);

}

System.out.println (bts.toString ());

//反序列化

IntWritable age2=new IntWritable ();

age2。readFields(新DataInputStream(新ByteArrayInputStream(包

.toByteArray ()))),

System.out.println (age2.get ());

ByteArrayInputStream姨=new ByteArrayInputStream (baos.toByteArray ());

DataInputStream说=new DataInputStream(姨);

System.out.println (dis.readInt ());

////测试用短类型方式的读取

//ShortWritable short1=new ShortWritable ();

//short1.readFields (dis);

//System.out.println (short1.get ());

//ShortWritable short2=new ShortWritable ();

//short2.readFields (dis);

//System.out.println (short2.get ());

}

}

Hadoop学习,int类型的序列化和反序列化——day07