This is an automated email from the ASF dual-hosted git repository.
lostluck pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 1754d03 [BEAM-7923] Screendiff Integration Tests (#11338)
add f7647ad [BEAM-9642] Add SDF execution units. (#11327)
No new revisions were added by this update.
Summary of changes:
sdks/go/pkg/beam/core/funcx/fn.go | 7 +-
sdks/go/pkg/beam/core/runtime/exec/fn.go | 12 +-
sdks/go/pkg/beam/core/runtime/exec/pardo.go | 17 +-
sdks/go/pkg/beam/core/runtime/exec/sdf.go | 297 +++++++++++++++++++
.../beam/core/runtime/exec/sdf_invokers_test.go | 34 ++-
sdks/go/pkg/beam/core/runtime/exec/sdf_test.go | 314 +++++++++++++++++++++
6 files changed, 664 insertions(+), 17 deletions(-)
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/sdf.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/sdf_test.go
