我有一个 .zip 文件放到名为“test.zip”的hadoop集群中。我正在尝试将其解压到hadoop集群中,并将其存储在名称下 test.txt 但是,文件没有得到解压缩,我下面的代码没有给我任何错误。代码能够解压文件,但不能将解压后的文件保存到集群中。
.zip
test.txt
owfi6suc1#
代码不会解压文件,但不会将其保存到hadoop集群您正在构建一个本地fileoutputstream,并且从未将任何内容写回hdfs
File newFile = new File(outputFolder + "/" + fileName); new File(newFile.getParent()).mkdirs();
需要用mkdirs调用 FileSystem fs 对象。或者尝试使用 fs.createFile() 方法,该方法返回可以写入的outputstream生成器
FileSystem fs
fs.createFile()
1条答案
按热度按时间owfi6suc1#
代码不会解压文件,但不会将其保存到hadoop集群
您正在构建一个本地fileoutputstream,并且从未将任何内容写回hdfs
需要用mkdirs调用
FileSystem fs
对象。或者尝试使用
fs.createFile()
方法,该方法返回可以写入的outputstream生成器