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

Posted to commits@beam.apache.org by mx...@apache.org on 2020/09/08 14:33:39 UTC

[beam] 01/01: Merge pull request #12759: [BEAM-10760] Generalize state cleanup optimization for global window

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

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

commit 5fd0010e52c5efee36760c302b03181e429da02f
Merge: d4e3729 26b087b
Author: Maximilian Michels <mx...@apache.org>
AuthorDate: Tue Sep 8 16:28:31 2020 +0200

    Merge pull request #12759: [BEAM-10760] Generalize state cleanup optimization for global window

 .../wrappers/streaming/DoFnOperator.java           |  24 ++-
 .../streaming/ExecutableStageDoFnOperator.java     |  32 +---
 .../streaming/state/FlinkStateInternals.java       |  96 ++++++++---
 .../wrappers/streaming/DoFnOperatorTest.java       | 190 ++++++++++++++-------
 .../streaming/ExecutableStageDoFnOperatorTest.java |  39 +----
 5 files changed, 237 insertions(+), 144 deletions(-)