You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ib...@apache.org on 2021/09/08 15:52:16 UTC

[beam] branch master updated (b6c62ca -> 9a72560)

This is an automated email from the ASF dual-hosted git repository.

ibzib pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from b6c62ca  Merge pull request #10546: [BEAM-9008] Add CassandraIO readAll method
     new 5a40505  [BEAM-12153] implement GroupByKey with CombinePerKey with Concatenate CombineFn
     new bccc5ea  [BEAM-11023] Increase memory in SS Validates runner tests to avoid OOM in beam coders
     new fb0b6a8  [BEAM-12727] extract Concatenate CombineFn to runner-core module to deduplicate it from many runners
     new 9a72560  Merge pull request #15267 from echauchot/BEAM-12153-spark-SS-runner-GBK-with-CPK

The 32901 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../org/apache/beam/runners/core/Concatenate.java  |  74 +++++++++++++++
 .../runners/flink/CreateStreamingFlinkView.java    |  50 +----------
 .../FlinkBatchPortablePipelineTranslator.java      |  53 +----------
 .../flink/FlinkBatchTransformTranslators.java      |  52 +----------
 .../SamzaPublishViewTransformOverride.java         |  43 +--------
 runners/spark/spark_runner.gradle                  |   2 +-
 .../batch/GroupByKeyTranslatorBatch.java           | 100 ++++++++++++---------
 7 files changed, 139 insertions(+), 235 deletions(-)
 create mode 100644 runners/core-java/src/main/java/org/apache/beam/runners/core/Concatenate.java