This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from ad0ca06 [BEAM-9667] Allow metrics in DoFn Setup (#11287)
add 9e01c5a [BEAM-9624] Adds Convert to Accumulators operator for use in
combiner lifting for streaming pipelines (#11271)
No new revisions were added by this update.
Summary of changes:
.../pipeline/src/main/proto/beam_runner_api.proto | 8 +++
.../core/construction/PTransformTranslation.java | 5 ++
sdks/go/pkg/beam/core/runtime/exec/combine.go | 27 ++++++++++
sdks/go/pkg/beam/core/runtime/exec/combine_test.go | 41 +++++++++++++-
sdks/go/pkg/beam/core/runtime/exec/translate.go | 7 ++-
.../org/apache/beam/fn/harness/CombineRunners.java | 15 ++++++
.../apache/beam/fn/harness/CombineRunnersTest.java | 63 ++++++++++++++++++++++
.../apache_beam/runners/worker/bundle_processor.py | 14 +++++
sdks/python/apache_beam/transforms/combiners.py | 6 +++
9 files changed, 182 insertions(+), 4 deletions(-)
