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 <rober...@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" <commits@beam.apache.org>.
