This is an automated email from the ASF dual-hosted git repository.
altay pushed a change to branch go-sdk
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 610db85 BEAM-3361 Increase Go gRPC message size
add e49cde3 Go SDK runtime revamp
new 60216f1 Merge pull request #4265 from herohde/runtime2
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/runtime/exec/coder.go | 16 +-
sdks/go/pkg/beam/core/runtime/exec/combine.go | 268 +++++++
sdks/go/pkg/beam/core/runtime/exec/combine_test.go | 67 ++
sdks/go/pkg/beam/core/runtime/exec/datasink.go | 85 +++
sdks/go/pkg/beam/core/runtime/exec/datasource.go | 170 +++++
.../guarded.go => core/runtime/exec/discard.go} | 52 +-
sdks/go/pkg/beam/core/runtime/exec/exec.go | 52 --
sdks/go/pkg/beam/core/runtime/exec/flatten.go | 75 ++
sdks/go/pkg/beam/core/runtime/exec/flatten_test.go | 49 ++
sdks/go/pkg/beam/core/runtime/exec/fn.go | 401 ++++++++++
sdks/go/pkg/beam/core/runtime/exec/fn_test.go | 123 ++++
sdks/go/pkg/beam/core/runtime/exec/fullvalue.go | 2 +-
.../pkg/beam/core/runtime/exec/fullvalue_test.go | 78 ++
sdks/go/pkg/beam/core/runtime/exec/multiplex.go | 62 ++
.../pkg/beam/core/runtime/exec/multiplex_test.go | 55 ++
sdks/go/pkg/beam/core/runtime/exec/nodes.go | 806 ---------------------
sdks/go/pkg/beam/core/runtime/exec/pardo.go | 193 +++++
sdks/go/pkg/beam/core/runtime/exec/pardo_test.go | 97 +++
sdks/go/pkg/beam/core/runtime/exec/plan.go | 139 ++++
.../runtime/{graphx/v1/gen.go => exec/status.go} | 13 +-
sdks/go/pkg/beam/core/runtime/exec/unit.go | 70 +-
sdks/go/pkg/beam/core/runtime/exec/unit_test.go | 111 +++
sdks/go/pkg/beam/core/runtime/exec/util.go | 82 +++
sdks/go/pkg/beam/core/runtime/harness/harness.go | 51 +-
sdks/go/pkg/beam/partition_test.go | 15 +-
sdks/go/pkg/beam/runners/direct/buffer.go | 165 +++++
sdks/go/pkg/beam/runners/direct/direct.go | 352 ++++-----
sdks/go/pkg/beam/runners/direct/gbk.go | 88 +++
sdks/go/pkg/beam/runners/direct/impulse.go | 62 ++
sdks/go/pkg/beam/runners/direct/nodes.go | 241 ------
30 files changed, 2650 insertions(+), 1390 deletions(-)
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/combine.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/combine_test.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/datasink.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/datasource.go
copy sdks/go/pkg/beam/{util/errorx/guarded.go => core/runtime/exec/discard.go}
(52%)
delete mode 100644 sdks/go/pkg/beam/core/runtime/exec/exec.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/flatten.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/flatten_test.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/fn.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/fn_test.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/fullvalue_test.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/multiplex.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/multiplex_test.go
delete mode 100644 sdks/go/pkg/beam/core/runtime/exec/nodes.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/pardo.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/pardo_test.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/plan.go
copy sdks/go/pkg/beam/core/runtime/{graphx/v1/gen.go => exec/status.go} (85%)
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/unit_test.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/util.go
create mode 100644 sdks/go/pkg/beam/runners/direct/buffer.go
create mode 100644 sdks/go/pkg/beam/runners/direct/gbk.go
create mode 100644 sdks/go/pkg/beam/runners/direct/impulse.go
delete mode 100644 sdks/go/pkg/beam/runners/direct/nodes.go
--
To stop receiving notification emails like this one, please contact
['"commits@beam.apache.org" <commits@beam.apache.org>'].
