Java连接hdfs下载目录下文件成压缩包文件流的工具类

你可以使用以下代码将HDFS目录下的文件打包成压缩包并返回压缩包文件流：

import org.apache.hadoop.conf.Configuration;
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.io.compress.GzipCodec;

import java.io.ByteArrayOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.URI;
import java.util.zip.ZipEntry;
import java.util.zip.ZipOutputStream;

public class HdfsZipDownloadUtil {

    public static ByteArrayOutputStream downloadAsZip(String hdfsPath) throws Exception {
        Configuration conf = new Configuration();
        FileSystem fs = FileSystem.get(URI.create(hdfsPath), conf);
        Path srcPath = new Path(hdfsPath);

        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        ZipOutputStream zos = new ZipOutputStream(baos);

        // 使用压缩算法
        CompressionCodec codec = new GzipCodec();
        CompressionOutputStream cos = codec.createOutputStream(zos);

        // 遍历目录下所有文件并压缩
        for (Path path : FileUtil.stat2Paths(fs.listStatus(srcPath))) {
            if (fs.isFile(path)) {
                String fileName = path.getName();
                ZipEntry zipEntry = new ZipEntry(fileName);
                zos.putNextEntry(zipEntry);
                InputStream inputStream = fs.open(path);
                IOUtils.copyBytes(inputStream, cos, conf);
                inputStream.close();
                zos.closeEntry();
            }
        }

        cos.finish();
        cos.close();
        zos.close();

        return baos;
    }

}

其中，`hdfsPath`是要下载的HDFS目录路径。该方法会将目录下所有文件打包成 `.zip` 格式的压缩包并返回压缩包文件流。你可以按照需要修改压缩算法和保存的文件格式。