MaxCompute：DownloadSession

public class DownloadSession {
    DownloadSession(Configuration conf, String projectName, String tableName,
                    String partitionSpec) throws TunnelException
    DownloadSession(Configuration conf, String projectName, String tableName,
                    String partitionSpec, String downloadId) throws TunnelException
    public String getId()
    public long getRecordCount()
    public TableSchema getSchema()
    public TableTunnel.DownloadStatus getStatus()
    public RecordReader openRecordReader(long start, long count)
    public RecordReader openRecordReader(long start, long count, boolean compress)
}

• 生命週期：從建立Download執行個體到下載結束。

• 建立Download執行個體：可以通過構造方法和TableTunnel建立。

  • 請求方式：同步。

  • 服務端（Server）會為該Download建立一個會話（Session），並產生唯一DownloadId標識該Download，用戶端可以通過getId擷取。

  • 服務端（Server）會對資料檔案建立索引，該操作開銷較大，因此當檔案多時，耗時較長。

  • 服務端（Server）返回總Record數，可啟動多個並發下載。

• 下載資料：

  • 請求方式：非同步。

  • 調用openRecordReader方法產生RecordReader執行個體，參數start標識起始位置，從0開始，取值範圍是>= 0， count標識記錄數，取值範圍是>0。

• 查看下載：

  • 請求方式：同步。

  • 調用getStatus擷取當前Download狀態。

• 四種狀態說明如下：

  • UNKNOWN：Server端剛建立一個Session時設定的初始值。

  • NORMAL：建立Download對象成功。

  • CLOSED：下載結束後。

  • EXPIRED：下載逾時。