You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2017/11/20 21:57:49 UTC
[2/2] beam git commit: This closes #4075: [BEAM-3137] Improved
validation of DynamicDestinations results in BigQueryIO.write
This closes #4075: [BEAM-3137] Improved validation of DynamicDestinations results in BigQueryIO.write
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/699e6d0f
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/699e6d0f
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/699e6d0f
Branch: refs/heads/master
Commit: 699e6d0f17f2a0b08d93217adbe14ddbff9555d7
Parents: 6fe6bc7 44d153a
Author: Eugene Kirpichov <ki...@google.com>
Authored: Mon Nov 20 13:57:32 2017 -0800
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Mon Nov 20 13:57:32 2017 -0800
----------------------------------------------------------------------
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 33 +++++++-
.../beam/sdk/io/gcp/bigquery/CreateTables.java | 28 +++++++
.../bigquery/DynamicDestinationsHelpers.java | 80 +++++++++++++++++---
.../beam/sdk/io/gcp/bigquery/PrepareWrite.java | 37 ++++++---
.../beam/sdk/io/gcp/bigquery/WriteTables.java | 29 +++++--
.../sdk/io/gcp/bigquery/BigQueryIOTest.java | 60 ++++++++++++++-
.../sdk/io/gcp/bigquery/FakeDatasetService.java | 2 +-
.../sdk/io/gcp/bigquery/FakeJobService.java | 1 +
8 files changed, 236 insertions(+), 34 deletions(-)
----------------------------------------------------------------------