java - 如何更新或写入 Hadoop 上的文件系统？

Question

所以我正在使用 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)));

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

谢谢，

Answer 1

你已经把读下来了，写起来也很简单。

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

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