You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ra...@apache.org on 2026/04/01 19:13:23 UTC
(beam) 01/01: Merge pull request #37851 from stankiewicz/metadata_propagation
This is an automated email from the ASF dual-hosted git repository.
radek pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 1c53cb26cd1e391acd204df65152d84e8a2d86ad
Merge: b7c87f23ce8 7a5c9822318
Author: Radosław Stankiewicz <ra...@google.com>
AuthorDate: Wed Apr 1 21:13:13 2026 +0200
Merge pull request #37851 from stankiewicz/metadata_propagation
Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation
...TimeBoundedSplittableProcessElementInvoker.java | 15 +++
.../apache/beam/runners/core/ReduceFnRunner.java | 2 +-
.../apache/beam/runners/core/SimpleDoFnRunner.java | 33 ++++++
.../beam/sdk/testing/TestOutputReceiver.java | 2 +
.../java/org/apache/beam/sdk/transforms/DoFn.java | 5 +
.../beam/sdk/transforms/DoFnOutputReceivers.java | 26 +----
.../org/apache/beam/sdk/transforms/DoFnTester.java | 21 ++++
.../apache/beam/sdk/transforms/Redistribute.java | 1 +
.../java/org/apache/beam/sdk/transforms/Reify.java | 11 +-
.../construction/SplittableParDoNaiveBounded.java | 27 +++--
.../apache/beam/sdk/util/construction/Timer.java | 2 +-
.../beam/sdk/values/ValueInSingleWindow.java | 4 +
.../org/apache/beam/sdk/values/WindowedValues.java | 32 ++++--
.../sdk/transforms/MetadataPropagationTest.java | 84 ++++++++++++++
.../sdk/transforms/reflect/DoFnInvokersTest.java | 3 +
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 122 ++++++++++++---------
16 files changed, 295 insertions(+), 95 deletions(-)