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

Posted to commits@beam.apache.org by ch...@apache.org on 2019/06/25 18:33:36 UTC

[beam] 01/01: Merge pull request #8832: [BEAM-7495] Add dynamic worker rebalancing to BigQuery Storage

This is an automated email from the ASF dual-hosted git repository.

chamikara pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit fd9ad839f5c342718063d59de5de3f4d99bbf035
Merge: 8745d6e aa8b3d0
Author: Chamikara Jayalath <ch...@apache.org>
AuthorDate: Tue Jun 25 11:33:20 2019 -0700

    Merge pull request #8832: [BEAM-7495] Add dynamic worker rebalancing to BigQuery Storage

 .../beam/sdk/io/gcp/bigquery/BigQueryServices.java |  19 +-
 .../sdk/io/gcp/bigquery/BigQueryServicesImpl.java  |  32 +-
 .../io/gcp/bigquery/BigQueryStorageSourceBase.java |  20 +-
 .../gcp/bigquery/BigQueryStorageStreamSource.java  | 165 +++++++---
 .../gcp/bigquery/BigQueryIOStorageQueryTest.java   |  23 +-
 .../io/gcp/bigquery/BigQueryIOStorageReadTest.java | 357 +++++++++++++++++----
 .../sdk/io/gcp/bigquery/FakeBigQueryServices.java  |  22 ++
 7 files changed, 535 insertions(+), 103 deletions(-)