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 f68f05e Merge pull request #4350: Integrate master into go-sdk
add d4b3624 Type-specialize custom decoders and encoders in Go SDK runtime
add 7bdffd6 Type-specialize iterators and side input in the Go SDK
add 9be0836 Add warnings if Go runtime registrations are overwritten
add 0b43308 Add reusable element coders in Go SDK runtime
new 2a0ba98 Merge pull request #4336 from herohde/runtime5
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/pkg/beam/core/runtime/exec/coder.go | 264 +-
sdks/go/pkg/beam/core/runtime/exec/datasink.go | 7 +-
sdks/go/pkg/beam/core/runtime/exec/datasource.go | 52 +-
sdks/go/pkg/beam/core/runtime/exec/decode.go | 90 +
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 | 7 +-
sdks/go/pkg/beam/core/runtime/exec/encode.go | 91 +
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 | 138 +-
.../pkg/beam/core/runtime/exec/fullvalue_test.go | 4 +-
sdks/go/pkg/beam/core/runtime/exec/input.go | 190 +
sdks/go/pkg/beam/core/runtime/exec/inputs.go | 21768 +++++++++++++++++++
sdks/go/pkg/beam/core/runtime/exec/inputs.tmpl | 144 +
sdks/go/pkg/beam/core/runtime/exec/pardo.go | 2 +-
sdks/go/pkg/beam/runners/direct/gbk.go | 6 +-
sdks/go/pkg/beam/testing/passert/passert.go | 16 +-
18 files changed, 25192 insertions(+), 275 deletions(-)
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/decode.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/decoders.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/decoders.tmpl
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/encode.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/encoders.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/encoders.tmpl
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/input.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/inputs.go
create mode 100644 sdks/go/pkg/beam/core/runtime/exec/inputs.tmpl
--
To stop receiving notification emails like this one, please contact
['"[email protected]" <[email protected]>'].
