我想通过hdfsapi访问本地文件系统。我有以下几点:
String filename;
//...
Path p = new Path(filename);
p.getFileSystem(new Configuration()).create(p);
问题是我在同一台机器上有hdfs节点,当我调用 p.getFileSystem(new Configuration()).create(p);
它试图创建一个hdfs文件,而不是本地文件。有没有办法通过 p.getFileSystem(new Configuration()).create(p)
?
1条答案
按热度按时间mftmpeh81#
文件名必须完全限定为
file://
```String filePath="file:///tmp/test.txt";
public void createFile(String path,Configuration conf) throws IOException {
FileSystem fs = FileSystem.get(URI.create(path), conf);
fs.create(new Path(path));
fs.close();
}