You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by jk...@apache.org on 2017/05/09 01:20:01 UTC

[2/2] beam git commit: This closes #2883

This closes #2883


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6a2586a4
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6a2586a4
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6a2586a4

Branch: refs/heads/master
Commit: 6a2586a4ee279f66fd4eae816e93fa8e397acf6b
Parents: f315cc9 fd1dda0
Author: Eugene Kirpichov <ki...@google.com>
Authored: Mon May 8 18:02:14 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Mon May 8 18:02:14 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(-)
----------------------------------------------------------------------