This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a commit to branch go-sdk
in repository https://gitbox.apache.org/repos/asf/beam.git
commit a328e441dbe28f233929b7b3a4a5408663fe7468
Merge: 52a598d b7dce98
Author: Robert Bradshaw <rober...@gmail.com>
AuthorDate: Tue Feb 6 16:33:10 2018 -0800
Merge pull request #4540 [BEAM-3302] Support CoGBK in the Go SDK
sdks/go/examples/cookbook/join/join.go | 111 ++++
sdks/go/pkg/beam/coder.go | 8 +-
sdks/go/pkg/beam/combine.go | 32 +-
sdks/go/pkg/beam/core/graph/bind.go | 51 +-
sdks/go/pkg/beam/core/graph/bind_test.go | 18 +-
sdks/go/pkg/beam/core/graph/coder/coder.go | 47 +-
sdks/go/pkg/beam/core/graph/edge.go | 160 +++--
sdks/go/pkg/beam/core/runtime/exec/coder.go | 28 +-
sdks/go/pkg/beam/core/runtime/exec/cogbk.go | 171 +++++
sdks/go/pkg/beam/core/runtime/exec/combine.go | 54 +-
sdks/go/pkg/beam/core/runtime/exec/combine_test.go | 4 +-
sdks/go/pkg/beam/core/runtime/exec/datasink.go | 18 +-
sdks/go/pkg/beam/core/runtime/exec/datasource.go | 20 +-
sdks/go/pkg/beam/core/runtime/exec/fn.go | 4 +-
sdks/go/pkg/beam/core/runtime/exec/fullvalue.go | 3 +
.../pkg/beam/core/runtime/exec/optimized/inputs.go | 695 +++------------------
.../beam/core/runtime/exec/optimized/inputs.tmpl | 33 +
sdks/go/pkg/beam/core/runtime/exec/pardo.go | 25 +-
sdks/go/pkg/beam/core/runtime/exec/pardo_test.go | 2 +-
sdks/go/pkg/beam/core/runtime/exec/plan.go | 2 +
sdks/go/pkg/beam/core/runtime/exec/translate.go | 433 +++++++++++++
sdks/go/pkg/beam/core/runtime/graphx/cobgk.go | 108 ++++
sdks/go/pkg/beam/core/runtime/graphx/coder.go | 68 +-
sdks/go/pkg/beam/core/runtime/graphx/coder_test.go | 8 +-
sdks/go/pkg/beam/core/runtime/graphx/serialize.go | 87 ++-
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 493 ++++-----------
.../pkg/beam/core/runtime/graphx/translate_test.go | 74 +--
sdks/go/pkg/beam/core/runtime/graphx/v1/v1.pb.go | 194 ++++--
sdks/go/pkg/beam/core/runtime/graphx/v1/v1.proto | 19 +-
sdks/go/pkg/beam/core/runtime/harness/datamgr.go | 9 +-
sdks/go/pkg/beam/core/runtime/harness/harness.go | 47 +-
sdks/go/pkg/beam/core/typex/class.go | 4 +-
sdks/go/pkg/beam/core/typex/class_test.go | 1 -
sdks/go/pkg/beam/core/typex/fulltype.go | 42 +-
sdks/go/pkg/beam/core/typex/fulltype_test.go | 28 +-
sdks/go/pkg/beam/core/typex/special.go | 10 +-
sdks/go/pkg/beam/gbk.go | 43 +-
sdks/go/pkg/beam/impulse.go | 4 +-
sdks/go/pkg/beam/io/bigqueryio/bigquery.go | 7 +
sdks/go/pkg/beam/io/textio/textio.go | 4 +
sdks/go/pkg/beam/runners/dataflow/translate.go | 182 +++++-
sdks/go/pkg/beam/runners/direct/direct.go | 48 +-
sdks/go/pkg/beam/runners/direct/gbk.go | 79 ++-
sdks/go/pkg/beam/testing/passert/passert.go | 4 +-
sdks/go/pkg/beam/x/debug/print.go | 4 +-
45 files changed, 1967 insertions(+), 1519 deletions(-)
--
To stop receiving notification emails like this one, please contact
rober...@apache.org.
