This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch go-sdk
in repository https://gitbox.apache.org/repos/asf/beam.git.
from c5a3ce0 Add initialization of active plans map.
new c67de93 Renamed Go runtime Caller to Func and added name
new 09e98e4 Use reflectx.Func as the fundamental function representation
new 8a9d916 CR: fix DynFn comments
new e019f19 CR: fix comments
The 4 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/cmd/symtab/main.go | 4 +-
sdks/go/pkg/beam/core/funcx/fn.go | 37 +-
sdks/go/pkg/beam/core/funcx/fn_test.go | 3 +-
sdks/go/pkg/beam/core/graph/bind_test.go | 4 +-
sdks/go/pkg/beam/core/graph/coder/coder.go | 8 +-
sdks/go/pkg/beam/core/graph/edge.go | 4 +-
sdks/go/pkg/beam/core/graph/fn.go | 34 +-
sdks/go/pkg/beam/core/runtime/exec/callers.go | 544 -
sdks/go/pkg/beam/core/runtime/exec/coder.go | 8 +-
sdks/go/pkg/beam/core/runtime/exec/combine.go | 4 +-
sdks/go/pkg/beam/core/runtime/exec/decode.go | 108 +-
sdks/go/pkg/beam/core/runtime/exec/decoders.go | 1347 --
sdks/go/pkg/beam/core/runtime/exec/decoders.tmpl | 89 -
sdks/go/pkg/beam/core/runtime/exec/emit.go | 2 -
sdks/go/pkg/beam/core/runtime/exec/emitters.go | 14214 ------------------
sdks/go/pkg/beam/core/runtime/exec/encode.go | 109 +-
sdks/go/pkg/beam/core/runtime/exec/encoders.go | 1171 --
sdks/go/pkg/beam/core/runtime/exec/encoders.tmpl | 81 -
sdks/go/pkg/beam/core/runtime/exec/fn.go | 19 +-
sdks/go/pkg/beam/core/runtime/exec/fn_test.go | 15 +-
sdks/go/pkg/beam/core/runtime/exec/input.go | 2 -
.../beam/core/runtime/exec/optimized/callers.go | 632 +
.../core/runtime/exec/{ => optimized}/callers.tmpl | 24 +-
.../beam/core/runtime/exec/optimized/decoders.go | 2407 ++++
.../beam/core/runtime/exec/optimized/decoders.tmpl | 146 +
.../beam/core/runtime/exec/optimized/emitters.go | 14215 +++++++++++++++++++
.../runtime/exec/{ => optimized}/emitters.tmpl | 32 +-
.../beam/core/runtime/exec/optimized/encoders.go | 2299 +++
.../beam/core/runtime/exec/optimized/encoders.tmpl | 146 +
.../scope.go => runtime/exec/optimized/gen.go} | 30 +-
.../core/runtime/exec/{ => optimized}/inputs.go | 4055 +++---
.../core/runtime/exec/{ => optimized}/inputs.tmpl | 26 +-
sdks/go/pkg/beam/core/runtime/exec/util.go | 11 -
sdks/go/pkg/beam/core/runtime/graphx/serialize.go | 11 +-
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 2 +-
sdks/go/pkg/beam/core/runtime/graphx/user.go | 11 +-
sdks/go/pkg/beam/core/util/reflectx/call.go | 64 +-
sdks/go/pkg/beam/core/util/reflectx/calls.go | 968 +-
sdks/go/pkg/beam/core/util/reflectx/calls.tmpl | 38 +-
sdks/go/pkg/beam/core/util/reflectx/json.go | 2 +-
sdks/go/pkg/beam/encoding.go | 23 +-
sdks/go/pkg/beam/partition.go | 62 +-
sdks/go/pkg/beam/transforms/filter/filter.go | 10 +-
sdks/go/pkg/beam/transforms/top/top.go | 33 +-
sdks/go/pkg/beam/transforms/top/top_test.go | 7 +-
sdks/go/pkg/beam/x/beamx/run.go | 2 +
46 files changed, 22823 insertions(+), 20240 deletions(-)
delete mode 100644 sdks/go/pkg/beam/core/runtime/exec/callers.go
delete mode 100644 sdks/go/pkg/beam/core/runtime/exec/decoders.go
delete mode 100644 sdks/go/pkg/beam/core/runtime/exec/decoders.tmpl
delete mode 100644 sdks/go/pkg/beam/core/runtime/exec/emitters.go
delete mode 100644 sdks/go/pkg/beam/core/runtime/exec/encoders.go
delete mode 100644 sdks/go/pkg/beam/core/runtime/exec/encoders.tmpl
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/optimized/callers.go
rename sdks/go/pkg/beam/core/runtime/exec/{ => optimized}/callers.tmpl (72%)
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/optimized/decoders.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/optimized/decoders.tmpl
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/optimized/emitters.go
rename sdks/go/pkg/beam/core/runtime/exec/{ => optimized}/emitters.tmpl (64%)
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/optimized/encoders.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/optimized/encoders.tmpl
copy sdks/go/pkg/beam/core/{graph/scope.go => runtime/exec/optimized/gen.go}
(51%)
rename sdks/go/pkg/beam/core/runtime/exec/{ => optimized}/inputs.go (70%)
rename sdks/go/pkg/beam/core/runtime/exec/{ => optimized}/inputs.tmpl (76%)
--
To stop receiving notification emails like this one, please contact
['"[email protected]" <[email protected]>'].
