This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a change to branch go-sdk
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 52a598d [BEAM-3388] Remove reflection from varint codecs
add 07e534b Changed core GBK to CoGBK
add 66ecd91 Add CoGBK support to direct runner and Join example
add 79fb7e1 [BEAM-3316] Translate bundle descriptors directly to
execution plans in Go SDK
add 1cf50dd Translate CoGBK into GBK for Dataflow and model pipeline
runners
add b7dce98 CR: [BEAM-3302] Support CoGBK in the Go SDK
new a328e44 Merge pull request #4540 [BEAM-3302] Support CoGBK in the Go
SDK
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/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(-)
create mode 100644 sdks/go/examples/cookbook/join/join.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/cogbk.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/translate.go
create mode 100644 sdks/go/pkg/beam/core/runtime/graphx/cobgk.go
--
To stop receiving notification emails like this one, please contact
rober...@apache.org.
