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 <[email protected]> Authored: Tue Mar 28 08:46:35 2017 -0700 Committer: Eugene Kirpichov <[email protected]> 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(-) ----------------------------------------------------------------------
