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 a805977 [BEAM-10637] fix: test stream service start/stop (#12464)
add be5e419 [BEAM-10289] Go Dynamic splitting full implementation.
add f5c9f71 [BEAM-10289] Avoiding blocking when dynamic splitting in Go.
add c710ecc Merge pull request #12350: [BEAM-10289] Dynamic splitting
implementation.
No new revisions were added by this update.
Summary of changes:
sdks/go/pkg/beam/core/runtime/exec/datasource.go | 127 ++++--
.../pkg/beam/core/runtime/exec/datasource_test.go | 188 ++++++++-
.../go/pkg/beam/core/runtime/exec/dynsplit_test.go | 456 +++++++++++++++++++++
sdks/go/pkg/beam/core/runtime/exec/plan.go | 23 +-
sdks/go/pkg/beam/core/runtime/exec/sdf.go | 168 ++++++--
.../beam/core/runtime/exec/sdf_invokers_test.go | 3 +-
sdks/go/pkg/beam/core/runtime/exec/sdf_test.go | 146 ++++++-
sdks/go/pkg/beam/core/runtime/exec/translate.go | 22 +-
sdks/go/pkg/beam/core/runtime/harness/harness.go | 22 +-
sdks/go/pkg/beam/core/sdf/sdf.go | 9 +-
.../beam/io/rtrackers/offsetrange/offsetrange.go | 35 +-
11 files changed, 1104 insertions(+), 95 deletions(-)
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/dynsplit_test.go
