You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2018/08/08 23:54:17 UTC
[beam] 01/01: [BEAM-4835] Adding in additional options for
BigQueryIO insert statements
This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 89e322198828702db239998d6dd29a574fe04898
Merge: 499c04e 6e83980
Author: Lukasz Cwik <lc...@google.com>
AuthorDate: Wed Aug 8 16:54:10 2018 -0700
[BEAM-4835] Adding in additional options for BigQueryIO insert statements
.../beam/sdk/io/gcp/bigquery/BatchLoads.java | 11 +-
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 34 +++++-
.../beam/sdk/io/gcp/bigquery/BigQueryServices.java | 4 +-
.../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 14 ++-
.../beam/sdk/io/gcp/bigquery/StreamingInserts.java | 60 ++++++++++-
.../beam/sdk/io/gcp/bigquery/StreamingWriteFn.java | 12 ++-
.../sdk/io/gcp/bigquery/StreamingWriteTables.java | 38 +++++--
.../beam/sdk/io/gcp/bigquery/WriteTables.java | 8 +-
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 3 +-
.../io/gcp/bigquery/BigQueryServicesImplTest.java | 118 ++++++++++++++++++---
.../beam/sdk/io/gcp/bigquery/BigQueryUtilTest.java | 3 +-
.../sdk/io/gcp/bigquery/FakeDatasetService.java | 7 +-
12 files changed, 268 insertions(+), 44 deletions(-)