This is an automated email from the ASF dual-hosted git repository.

kenn pushed a commit to branch go-sdk
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 4b69c364d5549ea5bb161457c13a228ee8637cce
Merge: f7e4e41 6834287
Author: Kenn Knowles <k...@kennknowles.com>
AuthorDate: Fri Feb 2 11:50:31 2018 -0800

    Merge pull request #4582: [BEAM-3597] Add optional function registration to 
Go SDK runtime

 sdks/go/pkg/beam/coder.go                          | 10 ++-
 sdks/go/pkg/beam/core/graph/coder/int.go           | 66 ---------------
 sdks/go/pkg/beam/core/graph/coder/varint.go        | 56 -------------
 sdks/go/pkg/beam/core/graph/coder/varint_test.go   | 64 ---------------
 .../core/{graph/coder => runtime/coderx}/int.go    | 79 +++++-------------
 .../core/{graph/coder => runtime/coderx}/varint.go | 96 +++-------------------
 .../{graph/coder => runtime/coderx}/varint_test.go | 76 +----------------
 sdks/go/pkg/beam/core/runtime/graphx/coder_test.go |  6 +-
 sdks/go/pkg/beam/core/runtime/graphx/serialize.go  | 11 +--
 .../pkg/beam/core/runtime/graphx/translate_test.go |  4 +-
 sdks/go/pkg/beam/core/runtime/graphx/user.go       |  8 +-
 sdks/go/pkg/beam/core/runtime/symbols.go           | 84 ++++++++++---------
 sdks/go/pkg/beam/encoding.go                       |  8 +-
 sdks/go/pkg/beam/forward.go                        |  8 ++
 sdks/go/pkg/beam/io/textio/textio.go               |  2 +
 sdks/go/pkg/beam/partition.go                      |  4 +
 sdks/go/pkg/beam/partition_test.go                 |  8 +-
 sdks/go/pkg/beam/testing/ptest/symbols.go          | 67 ---------------
 sdks/go/pkg/beam/transforms/filter/distinct.go     |  5 ++
 sdks/go/pkg/beam/util.go                           |  7 ++
 sdks/go/pkg/beam/x/debug/print.go                  |  1 +
 21 files changed, 133 insertions(+), 537 deletions(-)

-- 
To stop receiving notification emails like this one, please contact
k...@apache.org.

Reply via email to