This closes #3662: [BEAM-2700] Support load jobs in streaming

Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f7e8f886
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f7e8f886
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f7e8f886

Branch: refs/heads/master
Commit: f7e8f886c91ea9d0b51e00331eeb4484e2f6e000
Parents: 0f8e8dd 075d4d4
Author: Eugene Kirpichov <kirpic...@google.com>
Authored: Mon Aug 14 14:32:14 2017 -0700
Committer: Eugene Kirpichov <kirpic...@google.com>
Committed: Mon Aug 14 14:32:14 2017 -0700

----------------------------------------------------------------------
 .../beam/sdk/io/gcp/bigquery/BatchLoads.java    | 447 +++++++++++++------
 .../beam/sdk/io/gcp/bigquery/BigQueryIO.java    | 168 ++++++-
 .../sdk/io/gcp/bigquery/ReifyAsIterable.java    |  51 +++
 .../io/gcp/bigquery/WriteBundlesToFiles.java    |  15 +-
 .../sdk/io/gcp/bigquery/WritePartition.java     |  13 +-
 .../beam/sdk/io/gcp/bigquery/WriteRename.java   | 111 +++--
 .../beam/sdk/io/gcp/bigquery/WriteTables.java   |  38 +-
 .../sdk/io/gcp/bigquery/BigQueryIOTest.java     | 269 ++++++-----
 8 files changed, 770 insertions(+), 342 deletions(-)
----------------------------------------------------------------------


Reply via email to