beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [6/6] beam git commit: This closes #2271
Date Tue, 28 Mar 2017 15:51:48 GMT
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 <kirpichov@google.com>
Authored: Tue Mar 28 08:46:35 2017 -0700
Committer: Eugene Kirpichov <kirpichov@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(-)
----------------------------------------------------------------------



Mime
View raw message