This is an automated email from the ASF dual-hosted git repository. kennknowles pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit b20e5fd10afbcbc8bc845dd1146eb82416c8e5f3 Merge: 562273c38b0 9accecd14f9 Author: Kenneth Knowles <[email protected]> AuthorDate: Thu Sep 3 10:18:07 2026 -0400 Merge pull request #39893: Fix nullness in BigQueryIO .github/trigger_files/beam_PostCommit_Java.json | 1 + .../beam_PostCommit_Java_BigQueryEarlyRollout.json | 3 + .../beam_PostCommit_Java_DataflowV1.json | 1 + .../beam_PostCommit_Java_DataflowV2.json | 1 + .../AvroGenericRecordToStorageApiProto.java | 22 +- .../beam/sdk/io/gcp/bigquery/AvroRowWriter.java | 9 +- .../beam/sdk/io/gcp/bigquery/BatchLoads.java | 17 +- .../sdk/io/gcp/bigquery/BigQueryAvroUtils.java | 17 +- ...ueryExportReadSchemaTransformConfiguration.java | 8 +- .../BigQueryExportReadSchemaTransformProvider.java | 13 +- .../beam/sdk/io/gcp/bigquery/BigQueryHelpers.java | 38 ++- .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 373 ++++++++++++--------- .../sdk/io/gcp/bigquery/BigQueryIOTranslation.java | 269 +++++++++------ .../io/gcp/bigquery/BigQueryQuerySourceDef.java | 32 +- .../io/gcp/bigquery/BigQuerySchemaIOProvider.java | 7 +- .../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 49 ++- .../io/gcp/bigquery/BigQueryStorageAvroReader.java | 12 +- .../beam/sdk/io/gcp/bigquery/BigQueryUtils.java | 169 +++++----- .../gcp/bigquery/DynamicDestinationsHelpers.java | 12 +- .../beam/sdk/io/gcp/bigquery/RowWriterFactory.java | 7 +- .../io/gcp/bigquery/StorageApiConvertMessages.java | 7 +- .../StorageApiDynamicDestinationsBeamRow.java | 1 - ...StorageApiDynamicDestinationsGenericRecord.java | 4 +- .../StorageApiDynamicDestinationsProto.java | 12 +- .../gcp/bigquery/StorageApiFinalizeWritesDoFn.java | 6 - .../beam/sdk/io/gcp/bigquery/StorageApiLoads.java | 17 +- .../io/gcp/bigquery/StorageApiWritePayload.java | 1 - .../bigquery/StorageApiWritesShardedRecords.java | 4 +- .../beam/sdk/io/gcp/bigquery/StreamingInserts.java | 4 +- .../io/gcp/bigquery/TableRowToStorageApiProto.java | 11 +- .../io/gcp/bigquery/UpdateSchemaDestination.java | 26 +- .../BigQueryDirectReadSchemaTransformProvider.java | 32 +- .../BigQueryFileLoadsSchemaTransformProvider.java | 27 +- ...ueryStorageWriteApiSchemaTransformProvider.java | 102 +++--- .../providers/BigQueryWriteConfiguration.java | 18 + .../providers/PortableBigQueryDestinations.java | 6 +- 36 files changed, 786 insertions(+), 552 deletions(-)
