feat(bigquery): add zero-copy queryArrow API for Arrow VectorSchemaRoot streaming by jinseopkim0 · Pull Request #13944 · googleapis/google-cloud-java

feat(bigquery): add zero-copy queryArrow API for Arrow VectorSchemaRoot streaming

jinseopkim0

committed

a77fa67

refactor(bigquery): remove unused 6-argument constructor in ArrowQueryResultImpl

jinseopkim0

committed

fd3f657

refactor(bigquery): use strongly-typed Arrow Schema and VectorSchemaRoot.create in ArrowQueryResultImpl

jinseopkim0

committed

39cfdc8

style(bigquery): remove extraneous empty line in BigQueryImpl

jinseopkim0

committed

2a15918

fix(bigquery): resolve Mockito Java 8 JSpecify compatibility and optional client initialization in Arrow query

jinseopkim0

committed

840fa44

fix(bigquery): rethrow JVM Error in close and translate stream/storage exceptions to BigQueryException

jinseopkim0

committed

595181e

feat(bigquery): wait for incomplete fast-path query and stream ByteString zero-copy

jinseopkim0

committed

81b3e58

fix(bigquery): read results via Storage Read API when fast-path query completes asynchronously

jinseopkim0

committed

e82091c

fix(bigquery): address review comments on null checks, error handling, and concurrency

jinseopkim0

committed

5ea0018

fix(bigquery): close BigQueryReadClient, propagate headers, and document single mutated vector root

jinseopkim0

committed

0d57c12

fix(bigquery): remove checked Exception from BigQuery.close signature

jinseopkim0

committed

e023b9b

fix(bigquery): narrow lock scope in VectorBatchIterator to allow concurrent cancellation

jinseopkim0

committed

69db97a

fix(bigquery): set bqReadClient = null upon close

jinseopkim0

committed

c232380

fix(bigquery): prefetch and peek Arrow record batches to preserve Iterator contract

jinseopkim0

committed

c552c63

fix(bigquery): provide default no-op implementation for BigQuery.close

jinseopkim0

committed

d0d42e9

fix(bigquery): manage ArrowRecordBatch lifecycle to prevent premature deallocation

jinseopkim0

committed

f4315cc

fix(bigquery): ensure exception safe cleanup of ArrowRecordBatch and remove redundant lock

jinseopkim0

committed

be274e9

fix(bigquery): mock BigQueryReadClient directly without reflection

jinseopkim0

committed

2f74bb1

fix(bigquery): address review comments on batch loading and project id resolution

jinseopkim0

committed

d3401dd

fix(bigquery): protect Arrow batch deserialization under lock and ensure offset visibility

jinseopkim0

committed

4dec332

fix(bigquery): import ByteString and channel types instead of using FQCNs

jinseopkim0

committed

2c61dce

fix(bigquery): ensure new batch is tracked before closing old batch

jinseopkim0

committed

53ded7a

fix(bigquery): hold lock across stream initialization in VectorBatchIterator

jinseopkim0

committed

1036836

fix(bigquery): rethrow BigQueryException directly in hasNext to avoid redundant wrapping

jinseopkim0

committed

5757272

fix(bigquery): consolidate lock acquisition in VectorBatchIterator

jinseopkim0

committed

8dd58b6

fix(bigquery): perform blocking gRPC call outside lock during stream initialization

jinseopkim0

committed

62da1fd

fix(bigquery): translate IOException to BigQueryException inside getBigQueryReadClient

jinseopkim0

committed

9944385

fix(bigquery): simplify anonymous Callable to lambda in queryArrowWithTimeout

jinseopkim0

committed

26087a9

Navigation Menu

Uh oh!

feat(bigquery): add zero-copy queryArrow API for Arrow VectorSchemaRoot streaming - #13944

feat(bigquery): add zero-copy queryArrow API for Arrow VectorSchemaRoot streaming#13944
jinseopkim0 wants to merge 28 commits into
feat-bigquery-arrow-deserializerfrom
feat-bigquery-arrow-veneer

Commits on Sep 12, 2026

feat(bigquery): add zero-copy queryArrow API for Arrow VectorSchemaRoot streaming

refactor(bigquery): remove unused 6-argument constructor in ArrowQueryResultImpl

refactor(bigquery): use strongly-typed Arrow Schema and VectorSchemaRoot.create in ArrowQueryResultImpl

style(bigquery): remove extraneous empty line in BigQueryImpl

fix(bigquery): resolve Mockito Java 8 JSpecify compatibility and optional client initialization in Arrow query

fix(bigquery): rethrow JVM Error in close and translate stream/storage exceptions to BigQueryException

feat(bigquery): wait for incomplete fast-path query and stream ByteString zero-copy

fix(bigquery): read results via Storage Read API when fast-path query completes asynchronously

fix(bigquery): address review comments on null checks, error handling, and concurrency

fix(bigquery): close BigQueryReadClient, propagate headers, and document single mutated vector root

fix(bigquery): remove checked Exception from BigQuery.close signature

fix(bigquery): narrow lock scope in VectorBatchIterator to allow concurrent cancellation

fix(bigquery): set bqReadClient = null upon close

fix(bigquery): prefetch and peek Arrow record batches to preserve Iterator contract

fix(bigquery): provide default no-op implementation for BigQuery.close

fix(bigquery): manage ArrowRecordBatch lifecycle to prevent premature deallocation

fix(bigquery): ensure exception safe cleanup of ArrowRecordBatch and remove redundant lock

fix(bigquery): mock BigQueryReadClient directly without reflection

fix(bigquery): address review comments on batch loading and project id resolution

fix(bigquery): protect Arrow batch deserialization under lock and ensure offset visibility

fix(bigquery): import ByteString and channel types instead of using FQCNs

fix(bigquery): ensure new batch is tracked before closing old batch

fix(bigquery): hold lock across stream initialization in VectorBatchIterator

fix(bigquery): rethrow BigQueryException directly in hasNext to avoid redundant wrapping

fix(bigquery): consolidate lock acquisition in VectorBatchIterator

fix(bigquery): perform blocking gRPC call outside lock during stream initialization

fix(bigquery): translate IOException to BigQueryException inside getBigQueryReadClient

fix(bigquery): simplify anonymous Callable to lambda in queryArrowWithTimeout