Hadoop学习--测试压缩--day05

远行的心

　　import java.io.FileInputStream;
　　import java.io.FileOutputStream;
　　import org.apache.hadoop.conf.Configuration;
　　import org.apache.hadoop.io.IOUtils;
　　import org.apache.hadoop.io.compress.CompressionOutputStream;
　　import org.apache.hadoop.io.compress.DeflateCodec;
　　import org.apache.hadoop.util.ReflectionUtils;
　　import org.junit.BeforeClass;
　　import org.junit.Test;

　　public>　　private static Configuration conf;
　　@BeforeClass
　　public static void iniConf(){
　　conf = new Configuration();
　　}
　　/**
　　* 使用deflate压缩算法
　　*/
　　@Test
　　public void compressByDeflate() throws Exception{
　　//deflate编码器
　　String codecStr = "org.apache.hadoop.io.compress.DeflateCodec";

　　Class clazz = (Class)>　　DeflateCodec codec = ReflectionUtils.newInstance(clazz,conf);
　　//对输出流包装，产生新的压缩流
　　FileOutputStream fos = new FileOutputStream("E:/zhaopian.deflate");
　　CompressionOutputStream comOut = codec.createOutputStream(fos);
　　//写入流
　　IOUtils.copyBytes(new FileInputStream("E:/zhaopian.jpg"),comOut,1024);
　　}
　　/**
　　* 使用deflate压缩算法
　　*/
　　@Test
　　public void compressByDeflate2() throws Exception{
　　//直接实例化codec对象
　　DeflateCodec codec = new DeflateCodec();
　　//检查并设置conf对象
　　ReflectionUtils.setConf(codec,conf);
　　//对输出流包装，产生新的压缩流
　　FileOutputStream fos = new FileOutputStream("E:/zhaopian2.deflate");
　　CompressionOutputStream comOut = codec.createOutputStream(fos);
　　//写入流
　　IOUtils.copyBytes(new FileInputStream("E:/zhaopian.jpg"), comOut, 1024);
　　}
　　}