You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2017/12/21 17:43:32 UTC
[beam] 01/01: Merge pull request #4265 from herohde/runtime2
This is an automated email from the ASF dual-hosted git repository.
altay pushed a commit to branch go-sdk
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 60216f18cd071a7acb977edb8219682225eed972
Merge: 610db85 e49cde3
Author: Ahmet Altay <aa...@gmail.com>
AuthorDate: Thu Dec 21 09:43:28 2017 -0800
Merge pull request #4265 from herohde/runtime2
[BEAM-3308] Revamp Go SDK runtime
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 +++++
.../beam/core/runtime/exec/{exec.go => discard.go} | 67 +-
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 ++++
.../beam/core/runtime/exec/{exec.go => status.go} | 43 +-
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 ------
29 files changed, 2653 insertions(+), 1380 deletions(-)
--
To stop receiving notification emails like this one, please contact
"commits@beam.apache.org" <co...@beam.apache.org>.