This is an automated email from the ASF dual-hosted git repository. herohde pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit f31b789d591f7b8f6f96899a79fb6edf45ebcd34 Merge: 6637a50 e68296a Author: Henning Rohde <[email protected]> AuthorDate: Sat Aug 18 16:48:36 2018 -0700 [BEAM-3286] Add preliminary Go support for side input sdks/go/pkg/beam/core/runtime/exec/coder.go | 62 ++-- sdks/go/pkg/beam/core/runtime/exec/cogbk.go | 12 +- sdks/go/pkg/beam/core/runtime/exec/combine.go | 14 +- sdks/go/pkg/beam/core/runtime/exec/combine_test.go | 4 +- sdks/go/pkg/beam/core/runtime/exec/data.go | 70 +++++ sdks/go/pkg/beam/core/runtime/exec/datasink.go | 16 +- sdks/go/pkg/beam/core/runtime/exec/datasource.go | 28 +- sdks/go/pkg/beam/core/runtime/exec/discard.go | 2 +- sdks/go/pkg/beam/core/runtime/exec/flatten.go | 2 +- sdks/go/pkg/beam/core/runtime/exec/flatten_test.go | 2 +- sdks/go/pkg/beam/core/runtime/exec/fn.go | 6 +- sdks/go/pkg/beam/core/runtime/exec/fullvalue.go | 16 +- sdks/go/pkg/beam/core/runtime/exec/input.go | 12 +- sdks/go/pkg/beam/core/runtime/exec/multiplex.go | 2 +- .../pkg/beam/core/runtime/exec/multiplex_test.go | 2 +- .../pkg/beam/core/runtime/exec/optimized/inputs.go | 6 +- .../beam/core/runtime/exec/optimized/inputs.tmpl | 6 +- sdks/go/pkg/beam/core/runtime/exec/pardo.go | 129 +++++---- sdks/go/pkg/beam/core/runtime/exec/pardo_test.go | 14 +- sdks/go/pkg/beam/core/runtime/exec/plan.go | 2 +- sdks/go/pkg/beam/core/runtime/exec/sideinput.go | 150 ++++++++++ sdks/go/pkg/beam/core/runtime/exec/translate.go | 36 ++- sdks/go/pkg/beam/core/runtime/exec/unit.go | 2 +- sdks/go/pkg/beam/core/runtime/exec/unit_test.go | 17 +- sdks/go/pkg/beam/core/runtime/exec/util.go | 2 +- sdks/go/pkg/beam/core/runtime/exec/window.go | 2 +- sdks/go/pkg/beam/core/runtime/graphx/translate.go | 204 +++++++++----- sdks/go/pkg/beam/core/runtime/harness/datamgr.go | 173 +++++++----- .../pkg/beam/core/runtime/harness/datamgr_test.go | 9 +- sdks/go/pkg/beam/core/runtime/harness/harness.go | 13 +- sdks/go/pkg/beam/core/runtime/harness/session.go | 2 +- sdks/go/pkg/beam/core/runtime/harness/statemgr.go | 311 +++++++++++++++++++++ sdks/go/pkg/beam/core/runtime/pipelinex/clone.go | 38 +++ .../beam/runners/dataflow/dataflowlib/execute.go | 8 +- .../pkg/beam/runners/dataflow/dataflowlib/fixup.go | 59 ++++ sdks/go/pkg/beam/runners/direct/buffer.go | 13 +- sdks/go/pkg/beam/runners/direct/direct.go | 2 +- sdks/go/pkg/beam/runners/direct/gbk.go | 4 +- sdks/go/pkg/beam/runners/direct/impulse.go | 2 +- sdks/go/pkg/beam/runners/universal/universal.go | 4 + 40 files changed, 1133 insertions(+), 325 deletions(-)
