You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by re...@apache.org on 2021/06/09 15:51:06 UTC

[beam] branch master updated (f07d2a2 -> 9832f78)

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(-)