This is an automated email from the ASF dual-hosted git repository. kenn pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 4739405cdbc36c12198b6c6ee638afcbd6fab360 Merge: fcbb0340800 e761581b30d Author: Kenneth Knowles <[email protected]> AuthorDate: Mon Mar 2 12:27:36 2026 -0500 Merge pull request #37727: [Drain] Reduce Fn Runner changes ...TimeBoundedSplittableProcessElementInvoker.java | 21 ++++- .../org/apache/beam/runners/core/ReduceFn.java | 3 + .../beam/runners/core/ReduceFnContextFactory.java | 38 +++++++-- .../apache/beam/runners/core/ReduceFnRunner.java | 52 ++++++++---- .../core/SplittableParDoViaKeyedWorkItems.java | 1 + .../apache/beam/runners/core/WindowMatchers.java | 52 ++++++++++-- .../windmill/state/WindmillTagEncodingV1.java | 5 +- .../windmill/state/WindmillTagEncodingV2.java | 4 +- .../worker/StreamingGroupAlsoByWindowFnsTest.java | 95 +++++++++++++++++++++- .../dataflow/worker/WindmillKeyedWorkItemTest.java | 9 +- .../windmill/state/WindmillTagEncodingV2Test.java | 8 +- .../java/org/apache/beam/sdk/transforms/DoFn.java | 5 +- .../org/apache/beam/sdk/transforms/DoFnTester.java | 20 ++++- .../beam/sdk/values/ValueInSingleWindow.java | 20 +++-- 14 files changed, 280 insertions(+), 53 deletions(-)
