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/03/28 15:51:48 UTC
[6/6] beam git commit: This closes #2271
This closes #2271
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1339dd70
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1339dd70
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1339dd70
Branch: refs/heads/master
Commit: 1339dd70623d4a1737e10d5cdc22416ffdaf6d06
Parents: 434eadb 2381dee
Author: Eugene Kirpichov <ki...@google.com>
Authored: Tue Mar 28 08:46:35 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Tue Mar 28 08:46:35 2017 -0700
----------------------------------------------------------------------
.../sdk/io/gcp/bigquery/BatchLoadBigQuery.java | 182 ++
.../sdk/io/gcp/bigquery/BigQueryHelpers.java | 339 ++++
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 1915 +-----------------
.../io/gcp/bigquery/BigQueryQuerySource.java | 205 ++
.../io/gcp/bigquery/BigQueryServicesImpl.java | 2 +-
.../sdk/io/gcp/bigquery/BigQuerySourceBase.java | 196 ++
.../io/gcp/bigquery/BigQueryTableSource.java | 104 +
.../io/gcp/bigquery/PassThroughThenCleanup.java | 84 +
.../beam/sdk/io/gcp/bigquery/ShardedKey.java | 44 +
.../sdk/io/gcp/bigquery/ShardedKeyCoder.java | 87 +
.../sdk/io/gcp/bigquery/StreamWithDeDup.java | 98 +
.../sdk/io/gcp/bigquery/StreamingWriteFn.java | 186 ++
.../beam/sdk/io/gcp/bigquery/TableRowInfo.java | 34 +
.../sdk/io/gcp/bigquery/TableRowInfoCoder.java | 68 +
.../sdk/io/gcp/bigquery/TableRowWriter.java | 84 +
.../gcp/bigquery/TagWithUniqueIdsAndTable.java | 135 ++
.../sdk/io/gcp/bigquery/TransformingSource.java | 136 ++
.../beam/sdk/io/gcp/bigquery/WriteBundles.java | 82 +
.../sdk/io/gcp/bigquery/WritePartition.java | 79 +
.../beam/sdk/io/gcp/bigquery/WriteRename.java | 180 ++
.../beam/sdk/io/gcp/bigquery/WriteTables.java | 213 ++
.../sdk/io/gcp/bigquery/BigQueryIOTest.java | 93 +-
.../sdk/io/gcp/bigquery/BigQueryUtilTest.java | 12 +-
23 files changed, 2627 insertions(+), 1931 deletions(-)
----------------------------------------------------------------------