如何使用Java将Avro schema发送到GCP BigQuery？

import com.google.auth.oauth2.GoogleCredentials;
import com.google.cloud.bigquery.BigQuery;
import com.google.cloud.bigquery.BigQueryOptions;
import com.google.cloud.bigquery.Field;
import com.google.cloud.bigquery.Schema;
import com.google.cloud.bigquery.Table;
import com.google.cloud.bigquery.TableDefinition;
import com.google.cloud.bigquery.TableId;
import com.google.cloud.bigquery.TableInfo;

import org.apache.avro.Schema.Parser;

import java.io.FileInputStream;
import java.io.IOException;

public class AvroToBigQuery {
    public static void main(String[] args) throws IOException {
        // 解析Avro schema文件
        Parser parser = new Parser();
        org.apache.avro.Schema avroSchema = parser.parse(new FileInputStream("avro_schema.avsc"));

        // 创建BigQuery表模式
        Schema bigQuerySchema = Schema.of(
                Field.of("field1", Field.Type.STRING),
                Field.of("field2", Field.Type.INT64),
                // 添加其他字段
        );

        // 创建BigQuery客户端
        BigQuery bigquery = BigQueryOptions.newBuilder()
                .setCredentials(GoogleCredentials.fromStream(new FileInputStream("key.json")))
                .build()
                .getService();

        // 创建新的BigQuery表
        TableId tableId = TableId.of("dataset_name", "table_name");
        TableDefinition tableDefinition = StandardTableDefinition.of(bigQuerySchema);
        TableInfo tableInfo = TableInfo.newBuilder(tableId, tableDefinition).build();
        Table table = bigquery.create(tableInfo);

        // 上传Avro schema到BigQuery表
        table.load(FormatOptions.avro(), "gs://bucket_name/avro_schema.avro");

        // 验证上传是否成功
        String query = "SELECT * FROM `project.dataset_name.table_name` LIMIT 10";
        bigquery.query(QueryJobConfiguration.newBuilder(query).build());
    }
}