beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chamik...@apache.org
Subject [beam] 01/01: Merge pull request #8832: [BEAM-7495] Add dynamic worker rebalancing to BigQuery Storage
Date Tue, 25 Jun 2019 18:33:36 GMT
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 <chamikara@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(-)


Mime
View raw message