You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2018/01/09 17:47:45 UTC
[beam] branch go-sdk updated (f68f05e -> 2a0ba98)
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
['"commits@beam.apache.org" <co...@beam.apache.org>'].
[beam] 01/01: Merge pull request #4336 from herohde/runtime5
Posted by ro...@apache.org.
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 2a0ba9818c7f8468cdd1e2f8d28206882a5686bf
Merge: f68f05e 0b43308
Author: Robert Bradshaw <ro...@gmail.com>
AuthorDate: Tue Jan 9 09:47:41 2018 -0800
Merge pull request #4336 from herohde/runtime5
[BEAM-3388] Avoid various reflection and re-processing in the Go SDK runtime
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(-)
--
To stop receiving notification emails like this one, please contact
"commits@beam.apache.org" <co...@beam.apache.org>.