java - 使用java在hadoop中解压一个.zip文件

Question

我有一个名为“test.zip”的 hadoop 集群中的 .zip 文件。我正在尝试将其解压缩到 hadoop 集群中并将其存储在名称 test.txt 下，但是文件没有被解压缩，我的下面的代码没有给我任何错误。

代码能够解压缩文件，但无法将解压缩的文件保存到集群中。

Answer 1

The code does unzips the file but doesn't saves it to the hadoop cluster

您正在构建本地 FileOutputStream，并且永远不会将任何内容写回 HDFS

 File newFile = new File(outputFolder + "/" + fileName);
 new File(newFile.getParent()).mkdirs();

这些需要替换为对 FileSystem fs 对象的 mkdirs 调用。

或者尝试使用 fs.createFile() 方法，它返回一个您可以写入的 OutputStream 构建器