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/06/11 16:32:18 UTC

[beam] branch master updated (b5e5086 -> a834f2d)

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 b5e5086  [BEAM-12444] Fix bug when groupby.apply is used on a series grouped by a callable (#14930)
     add a834f2d  [BEAM-11086] Validate and Fix Go SDK windowing. (#14966)

No new revisions were added by this update.

Summary of changes:
 .../windowed_wordcount/windowed_wordcount.go       |  3 +-
 sdks/go/pkg/beam/core/runtime/exec/combine.go      | 20 ++++-
 sdks/go/pkg/beam/core/runtime/exec/combine_test.go | 20 +++--
 sdks/go/pkg/beam/core/runtime/exec/hash.go         | 53 +++++++++---
 sdks/go/pkg/beam/core/runtime/exec/hash_test.go    |  6 +-
 sdks/go/pkg/beam/core/runtime/exec/translate.go    |  4 +-
 sdks/go/pkg/beam/core/runtime/graphx/translate.go  |  4 +-
 sdks/go/test/integration/driver/driver.go          |  7 ++
 sdks/go/test/integration/primitives/windowinto.go  | 94 ++++++++++++++++++++++
 .../{flatten_test.go => windowinto_test.go}        | 13 ++-
 10 files changed, 190 insertions(+), 34 deletions(-)
 create mode 100644 sdks/go/test/integration/primitives/windowinto.go
 copy sdks/go/test/integration/primitives/{flatten_test.go => windowinto_test.go} (77%)