This closes #2609
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a1d82c20 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a1d82c20 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a1d82c20 Branch: refs/heads/DSL_SQL Commit: a1d82c20323c5abf05dad9c877fc4622db91d253 Parents: 17f0843 35db745 Author: Eugene Kirpichov <kirpic...@google.com> Authored: Wed May 3 16:24:21 2017 -0700 Committer: Eugene Kirpichov <kirpic...@google.com> Committed: Wed May 3 16:24:21 2017 -0700 ---------------------------------------------------------------------- .../beam/sdk/io/gcp/bigquery/BatchLoads.java | 129 +++--- .../sdk/io/gcp/bigquery/BigQueryHelpers.java | 74 ++-- .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 422 +++++++++++-------- .../sdk/io/gcp/bigquery/CalculateSchemas.java | 79 ++++ .../beam/sdk/io/gcp/bigquery/CreateTables.java | 65 ++- .../io/gcp/bigquery/DynamicDestinations.java | 178 ++++++++ .../bigquery/DynamicDestinationsHelpers.java | 192 +++++++++ .../beam/sdk/io/gcp/bigquery/PrepareWrite.java | 36 +- .../sdk/io/gcp/bigquery/StreamingInserts.java | 59 +-- .../io/gcp/bigquery/StreamingWriteTables.java | 8 + .../io/gcp/bigquery/TableDestinationCoder.java | 2 +- .../io/gcp/bigquery/WriteBundlesToFiles.java | 56 +-- .../sdk/io/gcp/bigquery/WritePartition.java | 69 ++- .../beam/sdk/io/gcp/bigquery/WriteTables.java | 112 ++--- .../sdk/io/gcp/bigquery/BigQueryIOTest.java | 336 +++++++++++---- 15 files changed, 1241 insertions(+), 576 deletions(-) ----------------------------------------------------------------------