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>'].