You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2022/06/01 19:46:25 UTC
[beam] 01/01: Merge pull request #16721: [BEAM-10608] Fix additional nullness errors in BigQueryIO
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 <ke...@apache.org>
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(-)