[Feature Request]: Support BigQuery reservation for Java BigQueryIO FILE_LOADS

Đang mở
  • Có gì không ổn?
#41,212 1 bình luận 0 reaction 1 người được giao Xem trên GitHub

Maintainer thường phản hồi trong vòng 1 ngày

@paragpratim đang làm issue này rồi.

Từ ngày 11/11/2026.

Đánh giá

Issue này chưa được đánh giá.

Mô tả

io java new feature P2
What would you like to happen?

Java BigQueryIO.Write with FILE_LOADS supports withLoadJobProjectId to choose the project in which load jobs run, but it does not expose an option to specify a reservation for those jobs.

Some organizations manage reservations centrally in a separate project and want individual load jobs to specify which reservation to use, rather than relying on a PIPELINE assignment for each job project. In this setup, the Dataflow worker service account would have access to the central reservation.

I propose adding an optional reservation setting to BigQueryIO.Write, for example:

BigQueryIO.writeTableRows()
    .to("project:dataset.table")
    .withMethod(BigQueryIO.Write.Method.FILE_LOADS)
    .withLoadJobReservation(
        "projects/central-project/locations/dataset-region/reservations/load-reservation-name");

The example above is one possible API; I'm open to other suggestions. It would be useful to support deferred values for templates and apply the reservation to all load jobs, including temporary-table and schema-update loads. If no reservation is specified, the current behavior should stay the same.

I'd like to verify that BigQuery uses the specified reservation for load jobs.

References:

Issue Priority

Priority: 2 (default / most feature requests should be filed as P2)

Issue Components
  • Component: Python SDK
  • Component: Java SDK
  • Component: Go SDK
  • Component: Typescript SDK
  • Component: IO connector
  • Component: Beam YAML
  • Component: Beam examples
  • Component: Beam playground
  • Component: Beam katas
  • Component: Website
  • Component: Infrastructure
  • Component: Spark Runner
  • Component: Flink Runner
  • Component: Prism Runner
  • Component: Hazelcast Jet Runner
  • Component: Google Cloud Dataflow Runner
Ngôn ngữ chính
Java
Star
8.7k
Fork
4.8k
Merge trung bình
2 ngày 12 giờ
Pull request đã merge (30 ngày)
371

Chuẩn bị môi trường

Bắt đầu từ đâu

  1. Đọc hết issue, rồi đọc hướng dẫn đóng góp của dự án.
  2. Bình luận trên issue rằng bạn sẽ nhận — tránh hai người làm cùng một việc.
  3. Fork repository và làm thay đổi trên một nhánh.
  4. Mở pull request có tham chiếu số hiệu của issue.

Issue khác của apache/beam

Tất cả issue của apache/beam

Issue tương tự

Thêm issue về Java

Nhận issue mới trong hộp thư của bạn

Bản tóm tắt ngắn những issue GitHub phù hợp với người mới.