This is an automated email from the ASF dual-hosted git repository. kenn pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 70cee1d125db0b62b2d660fc399e5a23845eb0e3 Merge: 36d0455459f 4e8d7fbf7df Author: Kenneth Knowles <[email protected]> AuthorDate: Wed Jun 1 12:46:17 2022 -0700 Merge pull request #16721: [BEAM-10608] Fix additional nullness errors in BigQueryIO .../org/apache/beam/gradle/BeamModulePlugin.groovy | 19 +++++- .../beam/examples/kotlin/snippets/Snippets.kt | 4 +- .../java/org/apache/beam/sdk/coders/VoidCoder.java | 2 +- .../org/apache/beam/sdk/state/ReadableState.java | 2 - .../org/apache/beam/sdk/state/ReadableStates.java | 5 +- .../java/org/apache/beam/sdk/transforms/DoFn.java | 9 +++ .../org/apache/beam/sdk/util/Preconditions.java | 35 +++++++++++ .../sdk/values/FailsafeValueInSingleWindow.java | 8 +-- .../main/java/org/apache/beam/sdk/values/KV.java | 8 ++- .../beam/sdk/values/ValueInSingleWindow.java | 14 +++-- .../beam/sdk/io/gcp/bigquery/AvroRowWriter.java | 6 +- .../beam/sdk/io/gcp/bigquery/BatchLoads.java | 14 ++--- .../sdk/io/gcp/bigquery/BatchedStreamingWrite.java | 29 ++++++---- .../sdk/io/gcp/bigquery/BigQueryAvroUtils.java | 6 +- .../beam/sdk/io/gcp/bigquery/BigQueryHelpers.java | 35 +++++++---- .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 2 +- .../sdk/io/gcp/bigquery/BigQueryIOMetadata.java | 10 ++-- .../sdk/io/gcp/bigquery/BigQueryQueryHelper.java | 19 +++--- .../io/gcp/bigquery/BigQueryQuerySourceDef.java | 3 +- .../io/gcp/bigquery/BigQueryResourceNaming.java | 7 +-- .../beam/sdk/io/gcp/bigquery/BigQueryServices.java | 3 +- .../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 25 ++++---- .../sdk/io/gcp/bigquery/BigQuerySourceBase.java | 28 ++++----- .../gcp/bigquery/BigQueryStorageArrowReader.java | 6 +- .../io/gcp/bigquery/BigQueryStorageAvroReader.java | 20 +++++-- .../gcp/bigquery/BigQueryStorageQuerySource.java | 15 ++--- .../io/gcp/bigquery/BigQueryStorageSourceBase.java | 11 ++-- .../gcp/bigquery/BigQueryStorageStreamSource.java | 57 +++++++++++------- .../gcp/bigquery/BigQueryStorageTableSource.java | 22 +++---- .../sdk/io/gcp/bigquery/BigQueryTableSource.java | 18 ++++-- .../io/gcp/bigquery/BigQueryTableSourceDef.java | 8 +-- .../beam/sdk/io/gcp/bigquery/BigQueryUtils.java | 32 ++++++----- .../io/gcp/bigquery/CreateTableDestinations.java | 7 ++- .../sdk/io/gcp/bigquery/CreateTableHelpers.java | 31 ++++++---- .../beam/sdk/io/gcp/bigquery/CreateTables.java | 17 +++--- .../sdk/io/gcp/bigquery/DynamicDestinations.java | 12 ++-- .../gcp/bigquery/DynamicDestinationsHelpers.java | 56 ++++++++++-------- .../beam/sdk/io/gcp/bigquery/ErrorContainer.java | 10 ++-- .../beam/sdk/io/gcp/bigquery/PrepareWrite.java | 11 ++-- .../beam/sdk/io/gcp/bigquery/ReifyAsIterable.java | 6 +- .../beam/sdk/io/gcp/bigquery/RetryManager.java | 16 +++--- .../beam/sdk/io/gcp/bigquery/RowWriterFactory.java | 23 +++++--- .../io/gcp/bigquery/StorageApiConvertMessages.java | 5 +- .../bigquery/StorageApiDynamicDestinations.java | 4 +- .../StorageApiDynamicDestinationsBeamRow.java | 4 +- .../StorageApiDynamicDestinationsTableRow.java | 7 ++- .../gcp/bigquery/StorageApiFinalizeWritesDoFn.java | 23 +++++--- .../bigquery/StorageApiFlushAndFinalizeDoFn.java | 12 ++-- .../bigquery/StorageApiWriteUnshardedRecords.java | 67 ++++++++++++---------- .../bigquery/StorageApiWritesShardedRecords.java | 18 +++--- .../beam/sdk/io/gcp/bigquery/StreamingInserts.java | 12 ++-- .../sdk/io/gcp/bigquery/StreamingWriteTables.java | 26 +++++---- .../beam/sdk/io/gcp/bigquery/TableDestination.java | 11 ++-- .../sdk/io/gcp/bigquery/TableDestinationCoder.java | 7 +-- .../io/gcp/bigquery/TableDestinationCoderV2.java | 7 +-- .../io/gcp/bigquery/TableDestinationCoderV3.java | 10 ++-- .../io/gcp/bigquery/TableRowToStorageApiProto.java | 18 +++--- .../beam/sdk/io/gcp/bigquery/TagWithUniqueIds.java | 7 +-- .../beam/sdk/io/gcp/bigquery/TestBigQuery.java | 30 +++++++--- .../bigquery/TwoLevelMessageConverterCache.java | 6 +- .../io/gcp/bigquery/UpdateSchemaDestination.java | 2 +- .../sdk/io/gcp/bigquery/WriteBundlesToFiles.java | 37 +++++++----- .../beam/sdk/io/gcp/bigquery/WritePartition.java | 16 +++--- .../beam/sdk/io/gcp/bigquery/WriteRename.java | 20 +++---- .../beam/sdk/io/gcp/bigquery/WriteResult.java | 49 ++++++++-------- .../beam/sdk/io/gcp/bigquery/WriteTables.java | 21 +++---- .../io/gcp/bigquery/BigQueryServicesImplTest.java | 12 +++- 67 files changed, 641 insertions(+), 461 deletions(-)
