如何在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和地方

完全合格