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
['"[email protected]" <[email protected]>'].
