beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject [32/50] [abbrv] beam git commit: This closes #2609
Date Thu, 04 May 2017 07:17:38 GMT
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 <kirpichov@google.com>
Authored: Wed May 3 16:24:21 2017 -0700
Committer: Eugene Kirpichov <kirpichov@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(-)
----------------------------------------------------------------------



Mime
View raw message