//对标准的输入的读取数据进行压缩，，然后将其写到标准的输出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 stubString 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();}}
流转的时光，都成为命途中美丽的点缀，
