This is an automated email from the ASF dual-hosted git repository.
reuvenlax pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from f07d2a2 Merge pull request #14941 from ibzib/BEAM-12439
add 9832f78 Merge pull request #14949: [BEAM-12356] Cache and shutdown
BigQuery services
No new revisions were added by this update.
Summary of changes:
.../sdk/io/gcp/bigquery/BatchedStreamingWrite.java | 27 ++++++++++++++--
.../beam/sdk/io/gcp/bigquery/BigQueryHelpers.java | 15 ++++++---
.../beam/sdk/io/gcp/bigquery/BigQueryServices.java | 4 +--
.../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 10 ++++++
.../sdk/io/gcp/bigquery/CreateTableHelpers.java | 5 ++-
.../gcp/bigquery/DynamicDestinationsHelpers.java | 11 +++++--
.../gcp/bigquery/StorageApiFinalizeWritesDoFn.java | 12 +++++++
.../bigquery/StorageApiFlushAndFinalizeDoFn.java | 12 +++++++
.../bigquery/StorageApiWriteUnshardedRecords.java | 22 +++++++++----
.../bigquery/StorageApiWritesShardedRecords.java | 31 ++++++++++++------
.../beam/sdk/io/gcp/bigquery/WriteRename.java | 26 +++++++++++++--
.../beam/sdk/io/gcp/bigquery/WriteTables.java | 37 ++++++++++++++++++++--
.../sdk/io/gcp/testing/FakeDatasetService.java | 3 ++
.../beam/sdk/io/gcp/testing/FakeJobService.java | 3 ++
14 files changed, 183 insertions(+), 35 deletions(-)
