This is an automated email from the ASF dual-hosted git repository.
reuvenlax pushed a change to branch release-2.45.0
in repository https://gitbox.apache.org/repos/asf/beam.git
from 7d07ffe68ba update cloudpickle version (#25143)
add ab5cebf5525 Handle schema updates in Storage API writes.
add 7f6c93ea039 Fix inconsistent cache bug
new ade83b355ee Merge pull request #25205: Cherry pick/fix bigquery
inconsistent cache
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:
.../beam/sdk/io/gcp/bigquery/AppendClientInfo.java | 120 ++++++++++--
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 18 +-
.../beam/sdk/io/gcp/bigquery/BigQueryServices.java | 8 +
.../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 11 ++
.../beam/sdk/io/gcp/bigquery/BigQueryUtils.java | 29 ---
.../sdk/io/gcp/bigquery/SplittingIterable.java | 61 +++++-
.../bigquery/StorageApiDynamicDestinations.java | 2 +
.../StorageApiDynamicDestinationsBeamRow.java | 8 +-
.../StorageApiDynamicDestinationsTableRow.java | 24 ++-
.../beam/sdk/io/gcp/bigquery/StorageApiLoads.java | 20 +-
.../io/gcp/bigquery/StorageApiWritePayload.java | 25 ++-
.../StorageApiWriteRecordsInconsistent.java | 12 +-
.../bigquery/StorageApiWriteUnshardedRecords.java | 146 +++++++++++---
.../bigquery/StorageApiWritesShardedRecords.java | 173 +++++++++++------
.../io/gcp/bigquery/TableRowToStorageApiProto.java | 110 +++++++++--
.../sdk/io/gcp/testing/FakeDatasetService.java | 63 +++++-
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 216 +++++++++++++++++++++
.../bigquery/TableRowToStorageApiProtoTest.java | 95 ++++++++-
18 files changed, 968 insertions(+), 173 deletions(-)
