This is an automated email from the ASF dual-hosted git repository. chamikara pushed a change to branch release-2.28.0 in repository https://gitbox.apache.org/repos/asf/beam.git.
from e5f3ee0 Merge pull request #13828: [BEAM-11689] (release-2.28.0) Add public.nexus.pentaho.org to offline repositories. add dda7c41 Merge pull request #13496 from [BEAM-11408] Integrate BigQuery sink streaming inserts with GroupIntoBatches add a7e598b Merge pull request #13832: [BEAM-11408] [cherry-pick] 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