You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/12/13 20:25:36 UTC
[beam] 01/01: Merge pull request #4237: [BEAM-3294] Make Go SDK
external transform a primitive
This is an automated email from the ASF dual-hosted git repository.
kenn pushed a commit to branch go-sdk
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 4a534b0964ae9a5319d9a7a1984a2ca303162864
Merge: 92883b2 2d695e7
Author: Kenn Knowles <ke...@kennknowles.com>
AuthorDate: Wed Dec 13 12:25:30 2017 -0800
Merge pull request #4237: [BEAM-3294] Make Go SDK external transform a primitive
sdks/go/pkg/beam/coder.go | 10 +--
sdks/go/pkg/beam/core/graph/coder/coder.go | 2 +
sdks/go/pkg/beam/core/graph/edge.go | 46 +++++++----
sdks/go/pkg/beam/core/graph/window/window.go | 1 +
sdks/go/pkg/beam/core/runtime/exec/exec.go | 2 +
sdks/go/pkg/beam/core/runtime/exec/nodes.go | 75 ------------------
sdks/go/pkg/beam/core/runtime/graphx/serialize.go | 17 ++--
sdks/go/pkg/beam/core/runtime/init.go | 3 +
sdks/go/pkg/beam/core/typex/fulltype.go | 1 +
sdks/go/pkg/beam/external.go | 95 +++++------------------
sdks/go/pkg/beam/forward.go | 2 +
sdks/go/pkg/beam/pcollection.go | 2 +-
sdks/go/pkg/beam/runners/dataflow/translate.go | 16 ----
sdks/go/pkg/beam/runners/direct/direct.go | 8 --
sdks/go/pkg/beam/util/syscallx/syscall.go | 6 +-
sdks/go/pkg/beam/util/syscallx/syscall_default.go | 4 +-
16 files changed, 80 insertions(+), 210 deletions(-)
--
To stop receiving notification emails like this one, please contact
"commits@beam.apache.org" <co...@beam.apache.org>.