使用Java将zip文件解压缩到HDFS

import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.zip.ZipEntry;
import java.util.zip.ZipInputStream;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;

Configuration conf = new Configuration();
FileSystem fs = FileSystem.get(conf);

String zipFilePath = "path/to/zip/file.zip";
InputStream inputStream = new FileInputStream(zipFilePath);
ZipInputStream zipInputStream = new ZipInputStream(inputStream);

ZipEntry entry = zipInputStream.getNextEntry();
while (entry != null) {
    String entryName = entry.getName();
    Path outputPath = new Path("hdfs://output/directory/" + entryName);
    fs.create(outputPath);
    byte[] buffer = new byte[1024];
    int bytesRead;
    while ((bytesRead = zipInputStream.read(buffer)) != -1) {
        fs.append(outputPath, buffer, 0, bytesRead);
    }
    zipInputStream.closeEntry();
    entry = zipInputStream.getNextEntry();
}

zipInputStream.close();
inputStream.close();