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 267f76f Merge pull request #10883: [BEAM-9331] Add better Row builders
add bbc0c18 [BEAM-8292] Portable Reshuffle for Go SDK (#11197)
No new revisions were added by this update.
Summary of changes:
sdks/go/pkg/beam/core/graph/edge.go | 20 +++
sdks/go/pkg/beam/core/runtime/exec/coder.go | 141 ++++++++++++-----
sdks/go/pkg/beam/core/runtime/exec/reshuffle.go | 168 +++++++++++++++++++++
sdks/go/pkg/beam/core/runtime/exec/translate.go | 21 +++
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 163 +++++++++++++++++++-
sdks/go/pkg/beam/gbk.go | 49 ++++++
.../beam/runners/dataflow/dataflowlib/translate.go | 3 +
sdks/go/pkg/beam/runners/direct/direct.go | 6 +
sdks/go/test/integration/driver.go | 2 +
sdks/go/test/integration/primitives/cogbk.go | 38 +++++
sdks/go/test/integration/primitives/cogbk_test.go | 12 ++
11 files changed, 585 insertions(+), 38 deletions(-)
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/reshuffle.go
