我想通过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();
}