This is an automated email from the ASF dual-hosted git repository.
pabloem pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from d289168 Merge pull request #13822 from y1chi/BEAM-11699
add f0a3f6d Merge pull request #13496 from [BEAM-11408] Integrate
BigQuery sink streaming inserts with GroupIntoBatches
No new revisions were added by this update.
Summary of changes:
.../beam/runners/dataflow/DataflowRunner.java | 4 +-
.../sdk/io/gcp/bigquery/BatchedStreamingWrite.java | 403 +++++++++++++++++++++
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 23 ++
.../beam/sdk/io/gcp/bigquery/StreamingInserts.java | 29 ++
.../beam/sdk/io/gcp/bigquery/StreamingWriteFn.java | 215 -----------
.../sdk/io/gcp/bigquery/StreamingWriteTables.java | 168 ++++++---
.../beam/sdk/io/gcp/bigquery/TagWithUniqueIds.java | 8 +-
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 73 +++-
8 files changed, 638 insertions(+), 285 deletions(-)
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BatchedStreamingWrite.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StreamingWriteFn.java
