Port DataflowJavaSDK-351 to Beam This closes #952
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0800a8cb Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0800a8cb Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/0800a8cb Branch: refs/heads/master Commit: 0800a8cb2b33856e5b0c93d669046648ebe7c01b Parents: 84e8bfb 9febae7 Author: Luke Cwik <[email protected]> Authored: Tue Sep 13 11:17:19 2016 -0700 Committer: Luke Cwik <[email protected]> Committed: Tue Sep 13 11:17:19 2016 -0700 ---------------------------------------------------------------------- .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 8 +-- .../sdk/io/gcp/bigquery/BigQueryServices.java | 7 +++ .../io/gcp/bigquery/BigQueryServicesImpl.java | 46 ++++++++++++++++ .../sdk/io/gcp/bigquery/BigQueryIOTest.java | 42 ++++++++++++++- .../gcp/bigquery/BigQueryServicesImplTest.java | 56 ++++++++++++++++++++ 5 files changed, 152 insertions(+), 7 deletions(-) ----------------------------------------------------------------------
