论坛 › Hadoop › Hadoop学习--map集合序列化--day07

opiuytr1 发表于 2017-1-4 10:05:30

Hadoop学习--map集合序列化--day07

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;

import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.MapWritable;
import org.apache.hadoop.io.Text;
import org.junit.Test;

public class TestMapWritable {
@Test
    public void test1() throws IOException {
       MapWritable map = new MapWritable();
       map.put(new IntWritable(100), new Text("tom"));
       ByteArrayOutputStream baos = new ByteArrayOutputStream();
       DataOutputStream dataOut = new DataOutputStream(baos);
       map.write(dataOut);
       dataOut.close();
       MapWritable map2 = new MapWritable();
       map2.readFields(new DataInputStream(new ByteArrayInputStream(baos.toByteArray())));
       
}
}

查看完整版本: Hadoop学习--map集合序列化--day07