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/12 23:27:40 UTC
[beam] branch go-sdk updated (008ba51 -> 92883b2)
This is an automated email from the ASF dual-hosted git repository.
kenn pushed a change to branch go-sdk
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 008ba51 Merge pull request #4230: [BEAM-2083] Make Scope a value type in Go SDK
add fffaed1 Add Go graph/pipeline translation
add f42ab80 Stage Go model pipeline for Dataflow
add eb4367d Use pipeline unmarhaller in runtime harness
add 722a7e1 CR: [BEAM-3287] Use model pipelines in Go SDK
add 99f3997 CR: [BEAM-3287] Use model pipelines in Go SDK
new 92883b2 Merge pull request #4213: [BEAM-3287] Use model pipelines in Go SDK
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
sdks/go/pkg/beam/core/graph/edge.go | 13 +-
sdks/go/pkg/beam/core/runtime/graphx/coder_test.go | 24 +-
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 654 +++++++++++++++++++++
.../pkg/beam/core/runtime/graphx/translate_test.go | 154 +++++
sdks/go/pkg/beam/core/runtime/graphx/tree.go | 121 ++++
sdks/go/pkg/beam/core/runtime/harness/harness.go | 59 +-
sdks/go/pkg/beam/core/runtime/harness/logging.go | 2 +-
sdks/go/pkg/beam/core/runtime/harness/translate.go | 343 -----------
.../beam/core/runtime/harness/translate_test.go | 298 ----------
sdks/go/pkg/beam/core/util/protox/base64.go | 9 +
.../beam/core/util/protox/protox.go} | 21 +-
sdks/go/pkg/beam/runners/dataflow/dataflow.go | 48 +-
12 files changed, 1049 insertions(+), 697 deletions(-)
create mode 100644 sdks/go/pkg/beam/core/runtime/graphx/translate.go
create mode 100644 sdks/go/pkg/beam/core/runtime/graphx/translate_test.go
create mode 100644 sdks/go/pkg/beam/core/runtime/graphx/tree.go
delete mode 100644 sdks/go/pkg/beam/core/runtime/harness/translate.go
delete mode 100644 sdks/go/pkg/beam/core/runtime/harness/translate_test.go
copy sdks/go/{cmd/beamctl/main.go => pkg/beam/core/util/protox/protox.go} (73%)
--
To stop receiving notification emails like this one, please contact
['"commits@beam.apache.org" <co...@beam.apache.org>'].
[beam] 01/01: Merge pull request #4213: [BEAM-3287] Use model
pipelines in Go SDK
Posted by ke...@apache.org.
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 92883b2be9a92892509bf5fcf25ddbe0e66b3d01
Merge: 008ba51 99f3997
Author: Kenn Knowles <ke...@kennknowles.com>
AuthorDate: Tue Dec 12 15:27:36 2017 -0800
Merge pull request #4213: [BEAM-3287] Use model pipelines in Go SDK
sdks/go/pkg/beam/core/graph/edge.go | 13 +-
sdks/go/pkg/beam/core/runtime/graphx/coder_test.go | 24 +-
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 654 +++++++++++++++++++++
.../pkg/beam/core/runtime/graphx/translate_test.go | 154 +++++
sdks/go/pkg/beam/core/runtime/graphx/tree.go | 121 ++++
sdks/go/pkg/beam/core/runtime/harness/harness.go | 59 +-
sdks/go/pkg/beam/core/runtime/harness/logging.go | 2 +-
sdks/go/pkg/beam/core/runtime/harness/translate.go | 343 -----------
.../beam/core/runtime/harness/translate_test.go | 298 ----------
sdks/go/pkg/beam/core/util/protox/base64.go | 9 +
.../beam/core/util/protox/{base64.go => protox.go} | 25 +-
sdks/go/pkg/beam/runners/dataflow/dataflow.go | 48 +-
12 files changed, 1046 insertions(+), 704 deletions(-)
--
To stop receiving notification emails like this one, please contact
"commits@beam.apache.org" <co...@beam.apache.org>.