beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From d...@apache.org
Subject [beam] branch master updated (ded0325 -> 76c6129)
Date Wed, 16 Dec 2020 16:35:28 GMT
This is an automated email from the ASF dual-hosted git repository.

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


    from ded0325  [BEAM-11075] Go SDK SideInput load tests (#13436)
     add f1c1514  [BEAM-11267] Remove unecessary reshuffle for stateful ParDo after keyed
operation.
     add 76c6129  Merge pull request #13353: [BEAM-11267] Remove unnecessary reshuffle for
stateful ParDo after key…

No new revisions were added by this update.

Summary of changes:
 .../FlinkStreamingPortablePipelineTranslator.java  |   4 +-
 .../flink/FlinkStreamingTransformTranslators.java  |  32 +++++-
 .../flink/FlinkStreamingTranslationContext.java    |  14 ++-
 .../wrappers/streaming/WorkItemKeySelector.java    |   9 +-
 .../FlinkStreamingPipelineTranslatorTest.java      | 109 +++++++++++++++++++++
 .../wrappers/streaming/WindowDoFnOperatorTest.java |   3 +-
 6 files changed, 159 insertions(+), 12 deletions(-)


Mime
View raw message