您的位置:首页 > 其它

对标准的输入的读取数据进行压缩,然后将其写到标准的输出

2015-02-23 20:33 471 查看
//对标准的输入的读取数据进行压缩,然后将其写到标准的输出

package com;

import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.io.IOUtils;

import org.apache.hadoop.io.compress.CompressionCodec;

import org.apache.hadoop.io.compress.CompressionOutputStream;

import org.apache.hadoop.util.ReflectionUtils;

public class StreamCompressor {

/**

* @param args

*/

public static void main(String[] args) {

// TODO Auto-generated method stub

String codecClassname =args[0];

Class<?> codecClass = Class.forName(codecClassname);

Configuration conf = new Configuration();

CompressionCodec codec = (CompressionCodec) ReflectionUtils.newInstance(codecClass, conf);

CompressionOutputStream out = codec.createOutputStream(System.out);

IOUtils.copyBytes(System.in, out, 4096, conf);

out.finish();

}

}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: 
相关文章推荐