如何使用Java处理数据流管道中的BigQuery插入错误？

<dependency>
    <groupId>com.google.cloud</groupId>
    <artifactId>google-cloud-bigquery</artifactId>
    <version>版本号</version>
</dependency>

import com.google.cloud.bigquery.BigQuery;
import com.google.cloud.bigquery.BigQueryOptions;

BigQuery bigquery = BigQueryOptions.getDefaultInstance().getService();

import com.google.cloud.bigquery.BigQueryError;
import com.google.cloud.bigquery.BigQueryException;
import com.google.cloud.bigquery.InsertAllRequest;
import com.google.cloud.bigquery.InsertAllResponse;
import com.google.cloud.bigquery.TableId;

TableId tableId = TableId.of("项目ID", "数据集ID", "表名");

InsertAllRequest.Builder insertRequestBuilder = InsertAllRequest.newBuilder(tableId);
insertRequestBuilder.addRow(rowId, rowData); // 添加要插入的数据行

InsertAllRequest insertRequest = insertRequestBuilder.build();

try {
    InsertAllResponse insertResponse = bigquery.insertAll(insertRequest);

    if (insertResponse.hasErrors()) {
        for (Map.Entry<Long, List<BigQueryError>> entry : insertResponse.getInsertErrors().entrySet()) {
            // 处理插入错误
            Long rowIdWithError = entry.getKey();
            List<BigQueryError> errors = entry.getValue();
            // 可以根据具体需求进行错误处理，例如记录日志或进行重试等
        }
    } else {
        // 插入成功
    }
} catch (BigQueryException e) {
    // 处理BigQuery异常
}