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 2021/10/20 18:44:37 UTC

[beam] branch master updated (76535e7 -> 070ea22)

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 76535e7  Minor: corrections to flink runner docs (#15759)
     add 070ea22  [BEAM-11087] Add default WindowMappingFn from Main to Side Input windows, validation test, unit tests (#15743)

No new revisions were added by this update.

Summary of changes:
 sdks/go/pkg/beam/core/runtime/exec/sideinput.go    | 11 +++--
 sdks/go/pkg/beam/core/runtime/exec/translate.go    | 50 +++++++++++++++++++--
 sdks/go/pkg/beam/core/runtime/exec/window.go       | 22 +++++++++-
 sdks/go/pkg/beam/core/runtime/exec/window_test.go  | 50 +++++++++++++++++++++
 sdks/go/pkg/beam/core/runtime/graphx/translate.go  | 25 ++++++++++-
 sdks/go/pkg/beam/pardo.go                          | 12 ++++-
 sdks/go/test/integration/integration.go            |  2 +
 sdks/go/test/integration/primitives/windowinto.go  | 51 ++++++++++++++++++++++
 .../test/integration/primitives/windowinto_test.go |  7 +++
 9 files changed, 221 insertions(+), 9 deletions(-)