如何在HDFS API中指定本地文件系统？

Question

我想通过HDFS API访问本地文件系统。我有以下几点：

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)访问本地文件系统？

Answer 1

文件名必须与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(); 
    } 

Works为S3，HDFS和地方

完全合格