beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From m..@apache.org
Subject [beam] branch master updated (ce4749ee -> f6ef903)
Date Wed, 03 Jun 2020 13:36:30 GMT
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


Mime
View raw message