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
