您好,登錄后才能下訂單哦!
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 class TestCompressDemo {
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<DeflateCodec> clazz = (Class<DeflateCodec>) Class.forName(codecStr);
DeflateCodec codec = ReflectionUtils.newInstance(clazz,conf);
//對輸出流包裝,產(chǎn)生新的壓縮流
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);
//對輸出流包裝,產(chǎn)生新的壓縮流
FileOutputStream fos = new FileOutputStream("E:/zhaopian2.deflate");
CompressionOutputStream comOut = codec.createOutputStream(fos);
//寫入流
IOUtils.copyBytes(new FileInputStream("E:/zhaopian.jpg"), comOut, 1024);
}
}
免責聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權內(nèi)容。