This is an automated email from the ASF dual-hosted git repository. apilloud pushed a commit to branch release-2.31.0 in repository https://gitbox.apache.org/repos/asf/beam.git
commit 809e10b51e2bd60c9fcb08270528b0071c9b21a5 Merge: ef28cc8 878cf7b Author: Andrew Pilloud <[email protected]> AuthorDate: Mon Jun 14 17:18:42 2021 -0700 Merge pull request #15009: [BEAM-12356] [release-2.31.0] Cache and shutdown BigQuery services .../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(-)
