feat(bigquery): add ArrowQueryResult and ArrowQueryResultImpl for Arrow result streaming - #13944

Merged

jinseopkim0 merged 38 commits into

mainfrom

feat-bigquery-arrow-veneer

Sep 16, 2026

Commits on Sep 14, 2026

feat(bigquery): add zero-copy queryArrow API for Arrow VectorSchemaRoot streaming
jinseopkim0
committed
7cc96f6
refactor(bigquery): remove unused 6-argument constructor in ArrowQueryResultImpl
jinseopkim0
committed
64d1729
refactor(bigquery): use strongly-typed Arrow Schema and VectorSchemaRoot.create in ArrowQueryResultImpl
jinseopkim0
committed
7c48bfd
style(bigquery): remove extraneous empty line in BigQueryImpl
jinseopkim0
committed
79d9cbd
fix(bigquery): resolve Mockito Java 8 JSpecify compatibility and optional client initialization in Arrow query
jinseopkim0
committed
359b644
fix(bigquery): rethrow JVM Error in close and translate stream/storage exceptions to BigQueryException
jinseopkim0
committed
d291158
feat(bigquery): wait for incomplete fast-path query and stream ByteString zero-copy
jinseopkim0
committed
1098b0c
fix(bigquery): read results via Storage Read API when fast-path query completes asynchronously
jinseopkim0
committed
531eb5e
fix(bigquery): address review comments on null checks, error handling, and concurrency
jinseopkim0
committed
8765958
fix(bigquery): close BigQueryReadClient, propagate headers, and document single mutated vector root
jinseopkim0
committed
4aa070b
fix(bigquery): remove checked Exception from BigQuery.close signature
jinseopkim0
committed
76b6294
fix(bigquery): narrow lock scope in VectorBatchIterator to allow concurrent cancellation
jinseopkim0
committed
e23176f
fix(bigquery): set bqReadClient = null upon close
jinseopkim0
committed
4906658
fix(bigquery): prefetch and peek Arrow record batches to preserve Iterator contract
jinseopkim0
committed
c687221
fix(bigquery): provide default no-op implementation for BigQuery.close
jinseopkim0
committed
e4c72f4
fix(bigquery): manage ArrowRecordBatch lifecycle to prevent premature deallocation
jinseopkim0
committed
8d49d2a
fix(bigquery): ensure exception safe cleanup of ArrowRecordBatch and remove redundant lock
jinseopkim0
committed
090f08b
fix(bigquery): mock BigQueryReadClient directly without reflection
jinseopkim0
committed
8702031
fix(bigquery): address review comments on batch loading and project id resolution
jinseopkim0
committed
012c717
fix(bigquery): protect Arrow batch deserialization under lock and ensure offset visibility
jinseopkim0
committed
6c65fe4
fix(bigquery): import ByteString and channel types instead of using FQCNs
jinseopkim0
committed
11ac9a5
fix(bigquery): ensure new batch is tracked before closing old batch
jinseopkim0
committed
fcf19c0
fix(bigquery): hold lock across stream initialization in VectorBatchIterator
jinseopkim0
committed
0e60635
fix(bigquery): rethrow BigQueryException directly in hasNext to avoid redundant wrapping
jinseopkim0
committed
2e556e2
fix(bigquery): consolidate lock acquisition in VectorBatchIterator
jinseopkim0
committed
8767fef
fix(bigquery): perform blocking gRPC call outside lock during stream initialization
jinseopkim0
committed
7ff06d1
fix(bigquery): translate IOException to BigQueryException inside getBigQueryReadClient
jinseopkim0
committed
7549809
fix(bigquery): simplify anonymous Callable to lambda in queryArrowWithTimeout
jinseopkim0
committed
7b170df
fix(bigquery): preserve existing Service contract by removing AutoCloseable from BigQuery
jinseopkim0
committed
6d600ef
refactor(bigquery): isolate Arrow result model and streaming iterator for PR 1
jinseopkim0
committed
c857596
docs(bigquery): add Javadoc comments to non-override methods in ArrowQueryResultImpl
jinseopkim0
committed
dc02899
refactor(bigquery): deduplicate loadBatch in ArrowQueryResultImpl
jinseopkim0
committed
3065daf
perf(bigquery): ensure zero-copy batch loading via ReadableByteChannel
jinseopkim0
committed
3942577
fix(bigquery): remove unused gax-grpc and grpc-api dependencies from pom.xml
jinseopkim0
committed
1b283db

Commits on Sep 15, 2026

Commits on Sep 16, 2026

chore: address review feedback on ArrowQueryResult documentation and cleanup
jinseopkim0
committed
11b22e2