You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by lo...@apache.org on 2023/06/02 17:48:23 UTC

[beam] branch master updated (25984047c47 -> 9db93581e47)

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 25984047c47 [GO SDK] - avroio nullable fields fix (#26812)
     add 9db93581e47 [#22737] Fit & Finish for Go SDK timer support. (#26782)

No new revisions were added by this update.

Summary of changes:
 sdks/go/examples/timer_wordcap/wordcap.go          | 104 +++--
 sdks/go/pkg/beam/core/graph/edge.go                |   1 -
 sdks/go/pkg/beam/core/runtime/exec/coder.go        |  33 +-
 sdks/go/pkg/beam/core/runtime/exec/datasource.go   |   6 +-
 .../pkg/beam/core/runtime/exec/datasource_test.go  |  23 +-
 sdks/go/pkg/beam/core/runtime/exec/fn.go           |   8 +-
 sdks/go/pkg/beam/core/runtime/exec/pardo.go        | 145 +++++--
 sdks/go/pkg/beam/core/runtime/exec/pardo_test.go   | 126 ++++++
 sdks/go/pkg/beam/core/runtime/exec/timers.go       | 348 +++++++++++----
 sdks/go/pkg/beam/core/runtime/exec/timers_test.go  | 470 ++++++++++++++++++++-
 sdks/go/pkg/beam/core/runtime/exec/translate.go    |  16 +-
 sdks/go/pkg/beam/core/runtime/graphx/translate.go  |  26 +-
 sdks/go/pkg/beam/core/timers/timers.go             |  34 +-
 sdks/go/pkg/beam/pardo.go                          |  11 -
 14 files changed, 1141 insertions(+), 210 deletions(-)