当前位置：马洪飞博客 > HDFS > 正文

压缩hdfs文件java源码

2018-01-29 分类：HDFS / Java 阅读(372) 评论(0)

hadoop2.7

源码来自网络，自己稍加修改；

package com.hdfs;
import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;
import javafx.scene.effect.Reflection;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataInputStream;
import org.apache.hadoop.fs.FSDataOutputStream;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
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 gzipHdfsFile {
static String hdfsFileDir = “”;
public static void gzip(String codecClassName) throws Exception{
String gzipFileDir = hdfsFileDir.concat(“.gz”);
//压缩文件
Class<?> codecClass = Class.forName(codecClassName);
Configuration conf = new Configuration();
FileSystem fs = FileSystem.get(conf);
CompressionCodec codec = (CompressionCodec) ReflectionUtils.newInstance(codecClass,conf);
//指定压缩文件输出路径
FSDataOutputStream outputStream = fs.create(new Path(gzipFileDir));
//指定被压缩的文件路径
FSDataInputStream in = fs.open(new Path(hdfsFileDir));
//创建压缩输出流
CompressionOutputStream out = codec.createOutputStream(outputStream);
IOUtils.copyBytes(in, out, conf);
IOUtils.closeStream(in);
IOUtils.closeStream(out);
}
public static void main(String[] args) throws Exception {
//获取文件路径参数，生成输出路径参数
hdfsFileDir = args[0];
//执行文件压缩
gzip(“org.apache.hadoop.io.compress.GzipCodec”);
}
}

压缩HDFS目录下的文件利用java来进行

最后拷贝到hadoop集群上运行，运行命令

输入：文件名完整路径：/mahf/test.txt

输出：压缩后文件名完整路径：/mahf/test.txt.gz

hadoop jar gzipHdfsFile.jar 文件完整路径(包含文件名!)

例如：hadoop jar gzipHdfsFile.jar /mahf/test.txt

执行完生成文件：/mahf/test.txt.gz

赞(0) 打赏

未经允许不得转载：马洪飞博客 » 压缩hdfs文件java源码

mhf

一个喜欢瞎折腾的人，至今一事无成...

相关推荐

评论抢沙发

但尽人事，莫问前程

联系我们联系我们

QQ咨询
QQ咨询
回顶
回顶部