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())));

 }

}

另外有需要云服务器可以了解下创新互联scvps.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。