通过java编码更新/替换google bigquery中的tabledata

<dependency>
    <groupId>com.google.cloud</groupId>
    <artifactId>google-cloud-bigquery</artifactId>
    <version>1.128.0</version>
</dependency>

import com.google.auth.oauth2.GoogleCredentials;
import com.google.cloud.bigquery.BigQuery;
import com.google.cloud.bigquery.BigQueryOptions;

// 从Service Account密钥文件中创建GoogleCredentials对象
GoogleCredentials credentials = GoogleCredentials.fromStream(new FileInputStream("path/to/service-account-key.json"));

// 创建BigQuery客户端
BigQuery bigquery = BigQueryOptions.newBuilder()
    .setCredentials(credentials)
    .build()
    .getService();

import com.google.cloud.bigquery.TableId;

// 指定目标表的项目ID、数据集ID和表ID
TableId tableId = TableId.of("project-id", "dataset-id", "table-id");

import com.google.cloud.bigquery.TableDataWriteChannel;
import com.google.cloud.bigquery.TableDataWriteChannel.Builder;

// 创建TableDataWriteChannel.Builder对象
Builder builder = bigquery.writer(tableId);

// 设置写入选项，例如写入模式和缓冲区大小
builder.setWriteDisposition(TableDataWriteChannel.WriteDisposition.WRITE_TRUNCATE); // 替换模式
builder.setBufferSize(1024 * 1024); // 设置缓冲区大小为1MB

// 创建TableDataWriteChannel对象
TableDataWriteChannel writer = builder.build();

import com.google.cloud.bigquery.InsertAllRequest;
import com.google.cloud.bigquery.InsertAllResponse;
import com.google.cloud.bigquery.InsertAllRequest.RowToInsert;

// 创建要插入的行数据
RowToInsert row = RowToInsert.of(
    "column1", "value1",
    "column2", "value2",
    // 添加更多的列和值...
);

// 创建InsertAllRequest对象并添加要插入的行数据
InsertAllRequest request = InsertAllRequest.newBuilder(tableId)
    .addRow(row)
    // 添加更多的行数据...
    .build();

// 执行插入操作并获取InsertAllResponse对象
InsertAllResponse response = bigquery.insertAll(request);

// 检查插入操作的结果
if (response.hasErrors()) {
    // 处理插入错误
} else {
    // 插入成功
}