This is an automated email from the ASF dual-hosted git repository.
reuvenlax pushed a commit to branch release-2.45.0
in repository https://gitbox.apache.org/repos/asf/beam.git
commit ade83b355eed496c7e23606ab63e86eddd1d3988
Merge: 7d07ffe68ba 7f6c93ea039
Author: Reuven Lax <re...@google.com>
AuthorDate: Fri Jan 27 08:41:58 2023 -0800
Merge pull request #25205: Cherry pick/fix bigquery inconsistent cache
.../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(-)
