暴走的程式碼…

　　這次研究的主要目的是為了存放海量的圖檔，並不會對檔案內容進行修改。

　　思考所需要的操作，發現只需要取得目錄列表、取得檔案列表、建立目錄、刪除目錄、上傳檔案、刪除檔案、下載檔案這幾個功能就夠了。

１、建立連線

　　建立一個 HDFSAccess 類別，並在建構式時傳入 HDFS 的客戶端進入端點及 HDFS 帳號。

public sealed class HDFSAccess
{
    private readonly WebHDFSClient webHDFSClient;

    public HDFSAccess(string uriString, string userName)
    {
        this.webHDFSClient = new WebHDFSClient(new Uri(uriString), userName);
    }
}

２、取得目錄列表

　　使用 GetDirectoryStatus 方法取得目錄列表。

public List<string> GetDirectories(string path)
{
    var directoryStatus = this.webHDFSClient.GetDirectoryStatus(path).Result;

    return directoryStatus.Directories.Select(d => d.PathSuffix).ToList();
}

３、取得檔案列表

　　使用 GetDirectoryStatus 方法取得檔案列表。

public List<string> GetFiles(string path)
{
    var directoryStatus = this.webHDFSClient.GetDirectoryStatus(path).Result;

    return directoryStatus.Files.Select(d => d.PathSuffix).ToList();
}

４、建立目錄

　　使用 CreateDirectory 方法建立目錄。

public bool CreateDirectory(string path)
{
    // 傳入路徑不包含根目錄時，預設會在根目錄「/」底下
    return this.webHDFSClient.CreateDirectory(path).Result;
}

５、刪除目錄

　　使用 DeleteDirectory 方法刪除目錄。

public bool DeleteDirectory(string path)
{
    // 傳入路徑不包含根目錄時，預設會在根目錄「/」底下
    return this.webHDFSClient.DeleteDirectory(path).Result;
}

６、上傳檔案

　　使用 CreateFile 方法上傳檔案至 HDFS。

public string CreateFile(string localFile, string remotePath)
{
    // 傳入遠端路徑不包含根目錄時，預設會在根目錄「/」底下
    return this.webHDFSClient.CreateFile(localFile, remotePath).Result;
}

７、刪除檔案

　　使用 DeleteDirectory 方法刪除檔案。

public bool DeleteFile(string path)
{
    // 傳入路徑不包含根目錄時，預設會在根目錄「/」底下
    return this.webHDFSClient.DeleteDirectory(path).Result;
}

８、下載檔案

　　使用 OpenFile 方法得到檔案 Stream，再轉存成實體檔案即可。

public HttpResponseMessage OpenFile(string path)
{
    // 傳入路徑不包含根目錄時，預設會在根目錄「/」底下
    return this.webHDFSClient.OpenFile(path).Result;
}