Forward port Dataflow PR-431, PR-454, PR-453 to Beam This closes #1039
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9b71f163 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9b71f163 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/9b71f163 Branch: refs/heads/master Commit: 9b71f1636fe6dc99528c18a6b7c47247c5456caa Parents: ecbc641 9f33e86 Author: Luke Cwik <[email protected]> Authored: Thu Oct 6 15:33:28 2016 -0700 Committer: Luke Cwik <[email protected]> Committed: Thu Oct 6 15:33:28 2016 -0700 ---------------------------------------------------------------------- .../org/apache/beam/sdk/util/PropertyNames.java | 1 + .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 177 ++++++++++++------- .../sdk/io/gcp/bigquery/BigQueryServices.java | 8 +- .../io/gcp/bigquery/BigQueryServicesImpl.java | 37 ++-- .../gcp/bigquery/BigQueryTableRowIterator.java | 14 +- .../sdk/io/gcp/bigquery/BigQueryIOTest.java | 132 ++++++++++++-- .../bigquery/BigQueryTableRowIteratorTest.java | 6 +- 7 files changed, 279 insertions(+), 96 deletions(-) ----------------------------------------------------------------------
