Closes #1400
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3e1a6281 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3e1a6281 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/3e1a6281 Branch: refs/heads/master Commit: 3e1a62815ca467951647788d59c00921bd02803a Parents: 3c4b693 5190083 Author: Dan Halperin <dhalp...@google.com> Authored: Thu Dec 15 11:46:03 2016 -0800 Committer: Dan Halperin <dhalp...@google.com> Committed: Thu Dec 15 11:46:03 2016 -0800 ---------------------------------------------------------------------- .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 48 +- .../sdk/io/gcp/bigquery/BigQueryServices.java | 7 +- .../io/gcp/bigquery/BigQueryServicesImpl.java | 121 ++++- .../io/gcp/bigquery/BigQueryTableInserter.java | 217 --------- .../sdk/io/gcp/bigquery/BigQueryIOTest.java | 456 +++++++++++++++---- .../gcp/bigquery/BigQueryServicesImplTest.java | 139 +++++- .../gcp/bigquery/BigQueryTableInserterTest.java | 245 ---------- .../sdk/io/gcp/bigquery/BigQueryUtilTest.java | 50 +- 8 files changed, 655 insertions(+), 628 deletions(-) ----------------------------------------------------------------------
