文档

BufferedWriter上传示例

更新时间:

本文通过代码示例向您介绍如何使用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。您可根据表的实际列名和类型进行设置。

  • 本页导读 (1)
文档反馈