This is an automated email from the ASF dual-hosted git repository.
mxm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from ce4749ee Merge pull request #11908: [BEAM-9948] Fix mascot invalid
directory link
add 85e1542 [BEAM-10164] Flink Batch Runner: Memory efficient combine
implementation for non-merging windows.
add f6ef903 Merge pull request #11889: [BEAM-10164] Flink Batch Runner:
Memory efficient combine implementation
No new revisions were added by this update.
Summary of changes:
.../flink/FlinkBatchTransformTranslators.java | 111 ++++++++++++-------
.../functions/FlinkPartialReduceFunction.java | 24 ++++-
.../translation/functions/FlinkReduceFunction.java | 27 +++--
.../functions/SingleWindowFlinkCombineRunner.java | 119 +++++++++++++++++++++
4 files changed, 232 insertions(+), 49 deletions(-)
create mode 100644
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/SingleWindowFlinkCombineRunner.java
