beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From danolive...@apache.org
Subject [beam] branch master updated (a805977 -> c710ecc)
Date Tue, 04 Aug 2020 23:58:40 GMT
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


Mime
View raw message