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 <[email protected]> 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(-)
