This is an automated email from the ASF dual-hosted git repository.
lostluck pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 32b67ec [BEAM-9891] Generate query execution summary table after
finishing jobs (#12601)
add 49a90de [BEAM-9919] Added an External Transform API to Go SDK (#12445)
No new revisions were added by this update.
Summary of changes:
.../go/examples/xlang/wordcount/xlang_wordcount.go | 111 +++++++++++++
sdks/go/pkg/beam/core/graph/edge.go | 43 ++++-
sdks/go/pkg/beam/core/graph/xlang.go | 131 +++++++++++++++
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 58 +++++--
sdks/go/pkg/beam/core/runtime/harness/harness.go | 2 +-
.../dial.go => core/runtime/xlangx/expand.go} | 29 ++--
sdks/go/pkg/beam/core/runtime/xlangx/translate.go | 178 ++++++++++++++++++++
.../beam/model/pipeline_v1/beam_runner_api.pb.go | 3 +-
sdks/go/pkg/beam/runners/universal/universal.go | 4 +
sdks/go/pkg/beam/xlang.go | 179 +++++++++++++++++++++
10 files changed, 706 insertions(+), 32 deletions(-)
create mode 100644 sdks/go/examples/xlang/wordcount/xlang_wordcount.go
create mode 100644 sdks/go/pkg/beam/core/graph/xlang.go
copy sdks/go/pkg/beam/{util/grpcx/dial.go => core/runtime/xlangx/expand.go}
(57%)
create mode 100644 sdks/go/pkg/beam/core/runtime/xlangx/translate.go
create mode 100644 sdks/go/pkg/beam/xlang.go
