This closes #2981
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e282601b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e282601b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e282601b Branch: refs/heads/release-2.0.0 Commit: e282601b7137afcf21ff0fea5dc6922098e61452 Parents: 3c6316a 1c7e35a Author: Dan Halperin <[email protected]> Authored: Tue May 9 09:39:58 2017 -0700 Committer: Dan Halperin <[email protected]> Committed: Tue May 9 09:39:58 2017 -0700 ---------------------------------------------------------------------- .../beam/sdk/io/gcp/bigquery/BatchLoads.java | 122 ++++++++++++++++--- .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 35 +++--- .../sdk/io/gcp/bigquery/ShardedKeyCoder.java | 3 +- .../sdk/io/gcp/bigquery/TableRowWriter.java | 59 +++++---- .../io/gcp/bigquery/WriteBundlesToFiles.java | 111 ++++++++++++++--- .../bigquery/WriteGroupedRecordsToFiles.java | 68 +++++++++++ .../sdk/io/gcp/bigquery/WritePartition.java | 38 +++--- .../beam/sdk/io/gcp/bigquery/WriteRename.java | 9 +- .../beam/sdk/io/gcp/bigquery/WriteResult.java | 2 +- .../beam/sdk/io/gcp/bigquery/WriteTables.java | 7 +- .../sdk/io/gcp/bigquery/BigQueryIOTest.java | 81 ++++++++---- .../sdk/io/gcp/bigquery/FakeJobService.java | 6 +- 12 files changed, 396 insertions(+), 145 deletions(-) ----------------------------------------------------------------------
