如何在hadoop上更新或写入文件系统?

bkhjykvo  于 2021-06-03  发布在  Hadoop
关注(0)|答案(1)|浏览(408)

因此,我正在使用hadoop上的一个文件系统,需要使用path对该文件系统进行一些更新。在这个文件系统中,我有不同的txt格式的文件。我可以使用路径来获取这些文件。下面我想我可以通过使用bufferedreader在hadoop上读取一个文本文件,但是还没有经过测试。

fs = FileSystem.get(URI.create(path), conf);
Path pt = new Path(out + "/" + name  + ".txt");
BufferedReader each_br = new BufferedReader(new InputStreamReader(fs.open(pt)));

我想使用路径写入特定文件。我想不通。有什么办法吗?
谢谢,

vsmadaxz

vsmadaxz1#

你已经读下来了,写作也一样简单。

fs = FileSystem.get(URI.create(path), conf);
FSDataOutputStream out = fs.create(new Path("myOutFile"));
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(out));

这将为您提供标准的java bufferedwriter。从那以后你应该可以做任何你想做的事。

相关问题