全部產品
Search
文件中心

MaxCompute:BufferedWriter上傳樣本

更新時間:Feb 28, 2024

本文通過程式碼範例向您介紹如何使用BufferedWriter介面實現資料上傳。

// 初始化MaxCompute和tunnel的代碼。
RecordWriter writer = null;
TableTunnel.UploadSession uploadSession = tunnel.createUploadSession(projectName, tableName);
try {
  int i = 0;
  // 產生TunnelBufferedWriter的執行個體。
  writer = uploadSession.openBufferedWriter();
  Record product = uploadSession.newRecord();
  for (String item : items) {
    product.setString("name", item);
    product.setBigint("id", i);
    // 調用write介面寫入資料。
    writer.write(product);
    i += 1;
  }
} finally {
  if (writer != null) {
    // 關閉TunnelBufferedWriter
    writer.close();
  }
}
// uploadSession提交,結束上傳。
uploadSession.commit();

代碼解釋

items:表示待上傳的資料,您可使用STRING類型的數組定義,例如:String[] arr={"s1","s2"}

name:為表中待寫入資料的name列,資料類型為STRING。您可根據表的實際列名和類型進行設定。

id:為表中待寫入資料的id列,資料類型為BIGINT。您可根據表的實際列名和類型進行設定。