读取BigQuery类形式的Java表数据(Pojo)

import com.google.cloud.bigquery.BigQuery;
import com.google.cloud.bigquery.BigQueryException;
import com.google.cloud.bigquery.BigQueryOptions;
import com.google.cloud.bigquery.FieldValueList;
import com.google.cloud.bigquery.QueryJobConfiguration;
import com.google.cloud.bigquery.TableResult;

public class BigQueryExample {

  public static void main(String[] args) {
    // 创建BigQuery客户端
    BigQuery bigquery = BigQueryOptions.getDefaultInstance().getService();

    // 构建查询
    String query = "SELECT column1, column2 FROM `project_id.dataset.table` WHERE condition";

    // 执行查询
    QueryJobConfiguration queryConfig = QueryJobConfiguration.newBuilder(query).build();
    TableResult result;
    try {
      result = bigquery.query(queryConfig);
    } catch (BigQueryException e) {
      // 处理查询错误
      System.err.println("Query failed: " + e.getMessage());
      return;
    }

    // 映射到Java类（POJO）
    for (FieldValueList row : result.iterateAll()) {
      String column1 = row.get("column1").getStringValue();
      int column2 = row.get("column2").getLongValue().intValue();

      // 处理查询结果
      // ...
    }
  }
}