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。您可根据表的实际列名和类型进行设置。