beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rober...@apache.org
Subject [beam] branch go-sdk updated (f68f05e -> 2a0ba98)
Date Tue, 09 Jan 2018 17:47:45 GMT
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" <commits@beam.apache.org>'].

Mime
View raw message