This is an automated email from the ASF dual-hosted git repository.
stankiewicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from d6b98ba9019 Bump minimatch in /scripts/ci/pr-bot (#37732)
add 21b033c07cf Refactor metadata propagation in ReduceFnRunner to support
extensible PipelineMetadata
add 110e75934ba Add missing dependency on model:fn-execution to
runners:core-java
add fd571c92f59 document asserts due to new state added
add 79f7db946b1 Fix propagation of metadata
new da391d0e3d7 Merge pull request #38230 from stankiewicz/drain_combiner
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
runners/core-java/build.gradle | 1 +
.../apache/beam/runners/core/CombinedMetadata.java | 87 ++++++++++++++++++++
.../runners/core/CombinedMetadataCombiner.java | 78 ++++++++++++++++++
.../runners/core/LateDataDroppingDoFnRunner.java | 8 +-
.../apache/beam/runners/core/MetadataCombiner.java | 12 ++-
.../apache/beam/runners/core/ReduceFnRunner.java | 55 ++++++++++---
.../beam/runners/core/CombinedMetadataTest.java | 70 ++++++++++++++++
.../apache/beam/runners/core/ReduceFnTester.java | 5 +-
.../wrappers/streaming/WindowDoFnOperatorTest.java | 10 +++
.../beam/runners/dataflow/worker/WindmillSink.java | 8 +-
.../worker/StreamingDataflowWorkerTest.java | 37 +++++++--
.../org/apache/beam/sdk/values/WindowedValues.java | 4 +
.../sdk/transforms/MetadataPropagationTest.java | 95 ++++++++++++++++++++--
13 files changed, 433 insertions(+), 37 deletions(-)
create mode 100644
runners/core-java/src/main/java/org/apache/beam/runners/core/CombinedMetadata.java
create mode 100644
runners/core-java/src/main/java/org/apache/beam/runners/core/CombinedMetadataCombiner.java
copy .test-infra/kafka/bitnami/provider.tf =>
runners/core-java/src/main/java/org/apache/beam/runners/core/MetadataCombiner.java
(81%)
create mode 100644
runners/core-java/src/test/java/org/apache/beam/runners/core/CombinedMetadataTest.java
