This is an automated email from the ASF dual-hosted git repository.
kenn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 36d0455459f Fail Javadoc aggregateJavadoc task if there's an error
(#17801)
add a31d329aa7b Fix parsing of -PenableCheckerFramework in build
add 4e8d7fbf7df Fix additional nullness errors in BigQueryIO
new 70cee1d125d Merge pull request #16721: [BEAM-10608] Fix additional
nullness errors in BigQueryIO
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../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(-)
