This is an automated email from the ASF dual-hosted git repository.
danoliveira pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from f0e14fb Merge pull request #17039 Update generated dataflow apitools
messages.
add 95a5c26 [BEAM-10976] Bundle finalization: Harness and some exec
changes (#16980)
No new revisions were added by this update.
Summary of changes:
sdks/go/pkg/beam/core/runtime/exec/combine.go | 12 ++--
sdks/go/pkg/beam/core/runtime/exec/fn.go | 53 +++++++++++---
sdks/go/pkg/beam/core/runtime/exec/fn_test.go | 62 ++++++++++++++--
sdks/go/pkg/beam/core/runtime/exec/pardo.go | 9 +--
sdks/go/pkg/beam/core/runtime/exec/plan.go | 50 +++++++++++++
sdks/go/pkg/beam/core/runtime/exec/util.go | 2 +-
sdks/go/pkg/beam/core/runtime/harness/harness.go | 92 ++++++++++++++++++++----
sdks/go/pkg/beam/runners/direct/buffer.go | 1 -
8 files changed, 238 insertions(+), 43 deletions(-)
