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

vdgimpew  于 2021-05-29  发布在  Hadoop
关注(0)|答案(1)|浏览(426)

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

owfi6suc

owfi6suc1#

代码不会解压文件,但不会将其保存到hadoop集群
您正在构建一个本地fileoutputstream,并且从未将任何内容写回hdfs

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

需要用mkdirs调用 FileSystem fs 对象。
或者尝试使用 fs.createFile() 方法,该方法返回可以写入的outputstream生成器

相关问题