You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2017/05/04 07:17:38 UTC
[32/50] [abbrv] beam git commit: This closes #2609
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 <ki...@google.com>
Authored: Wed May 3 16:24:21 2017 -0700
Committer: Eugene Kirpichov <ki...@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(-)
----------------------------------------------------------------------