This closes #1873
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/77b13660 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/77b13660 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/77b13660 Branch: refs/heads/master Commit: 77b1366039f3bfc7b56304b538ac720f57869246 Parents: e9cd411 21e2cf6 Author: Dan Halperin <dhalp...@google.com> Authored: Tue Jan 31 17:11:46 2017 -0800 Committer: Dan Halperin <dhalp...@google.com> Committed: Tue Jan 31 17:11:46 2017 -0800 ---------------------------------------------------------------------- .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 4 +- .../sdk/io/gcp/bigquery/BigQueryServices.java | 3 +- .../io/gcp/bigquery/BigQueryServicesImpl.java | 17 ++-- .../gcp/bigquery/BigQueryTableRowIterator.java | 82 ++++++++------------ .../sdk/io/gcp/bigquery/BigQueryIOTest.java | 3 +- .../bigquery/BigQueryTableRowIteratorTest.java | 51 ++++++------ 6 files changed, 67 insertions(+), 93 deletions(-) ----------------------------------------------------------------------