You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2022/07/08 16:15:41 UTC
[beam] branch asf-site updated: Publishing website 2022/07/08 16:15:33 at commit d44c044
This is an automated email from the ASF dual-hosted git repository.
git-site-role pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 16063c815e3 Publishing website 2022/07/08 16:15:33 at commit d44c044
16063c815e3 is described below
commit 16063c815e3bc43c7f31fff84207f20cd6db0e94
Author: jenkins <bu...@apache.org>
AuthorDate: Fri Jul 8 16:15:34 2022 +0000
Publishing website 2022/07/08 16:15:33 at commit d44c044
---
website/generated-content/documentation/index.xml | 8 ++++----
.../documentation/programming-guide/index.html | 10 +++++-----
website/generated-content/sitemap.xml | 2 +-
3 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/website/generated-content/documentation/index.xml b/website/generated-content/documentation/index.xml
index 1afc1b9df8b..16920ccfee8 100644
--- a/website/generated-content/documentation/index.xml
+++ b/website/generated-content/documentation/index.xml
@@ -12302,10 +12302,10 @@ version = “v” 1*(DIGIT / “.”) ; For example, ‘v1.2’</code></pr
lower-level <a href="https://pkg.go.dev/github.com/apache/beam/sdks/v2/go/pkg/beam#CrossLanguage">CrossLanguage</a>
function to access the transform.</p>
<p><strong>Expansion Services</strong></p>
-<p>The Go SDK does not yet support automatically starting an expansion service. In order to use
-cross-language transforms, you must manually start any necessary expansion services on your local
-machine and ensure they are accessible to your code during pipeline construction; see more at
-<a href="https://issues.apache.org/jira/browse/BEAM-12862">BEAM-12862</a>.</p>
+<p>The Go SDK supports automatically starting Java expansion services if an expansion address is not provided, although this is slower than
+providing a persistent expansion service. Many wrapped Java transforms manage perform this automatically; if you wish to do this manually, use the <code>xlangx</code> package&rsquo;s
+<a href="https://pkg.go.dev/github.com/apache/beam/sdks/v2@v2.40.0/go/pkg/beam/core/runtime/xlangx#UseAutomatedJavaExpansionService">UseAutomatedJavaExpansionService()</a> function. In order to use Python cross-language transforms, you must manually start any necessary expansion
+services on your local machine and ensure they are accessible to your code during pipeline construction.</p>
<p><strong>Using an SDK wrapper</strong></p>
<p>To use a cross-language transform through an SDK wrapper, import the package for the SDK wrapper
and call it from your pipeline as shown in the example:</p>
diff --git a/website/generated-content/documentation/programming-guide/index.html b/website/generated-content/documentation/programming-guide/index.html
index 1826fc611ea..ecf8eb2a206 100644
--- a/website/generated-content/documentation/programming-guide/index.html
+++ b/website/generated-content/documentation/programming-guide/index.html
@@ -4456,10 +4456,10 @@ version = “v” 1*(DIGIT / “.”) ; For example, ‘v1.2’</code></pre></d
<span class=n>assert_that</span><span class=p>(</span><span class=n>res</span><span class=p>,</span> <span class=n>equal_to</span><span class=p>([</span><span class=s1>'0a'</span><span class=p>,</span> <span class=s1>'0b'</span><span class=p>]))</span>
</code></pre></div><p>For additional examples, see <a href=https://github.com/apache/beam/blob/master/examples/multi-language/python/addprefix.py>addprefix.py</a> and <a href=https://github.com/apache/beam/blob/master/examples/multi-language/python/javacount.py>javacount.py</a>.</p></li><li><p>After the job has been submitted to the Beam runner, shut down the expansion service by terminating the expansion service process.</p></li></ol><h4 id=1323-using-cross-language-transforms-in-a-go-p [...]
lower-level <a href=https://pkg.go.dev/github.com/apache/beam/sdks/v2/go/pkg/beam#CrossLanguage>CrossLanguage</a>
-function to access the transform.</p><p><strong>Expansion Services</strong></p><p>The Go SDK does not yet support automatically starting an expansion service. In order to use
-cross-language transforms, you must manually start any necessary expansion services on your local
-machine and ensure they are accessible to your code during pipeline construction; see more at
-<a href=https://issues.apache.org/jira/browse/BEAM-12862>BEAM-12862</a>.</p><p><strong>Using an SDK wrapper</strong></p><p>To use a cross-language transform through an SDK wrapper, import the package for the SDK wrapper
+function to access the transform.</p><p><strong>Expansion Services</strong></p><p>The Go SDK supports automatically starting Java expansion services if an expansion address is not provided, although this is slower than
+providing a persistent expansion service. Many wrapped Java transforms manage perform this automatically; if you wish to do this manually, use the <code>xlangx</code> package’s
+<a href=https://pkg.go.dev/github.com/apache/beam/sdks/v2@v2.40.0/go/pkg/beam/core/runtime/xlangx#UseAutomatedJavaExpansionService>UseAutomatedJavaExpansionService()</a> function. In order to use Python cross-language transforms, you must manually start any necessary expansion
+services on your local machine and ensure they are accessible to your code during pipeline construction.</p><p><strong>Using an SDK wrapper</strong></p><p>To use a cross-language transform through an SDK wrapper, import the package for the SDK wrapper
and call it from your pipeline as shown in the example:</p><div class=highlight><pre class=chroma><code class=language-go data-lang=go><span class=kn>import</span> <span class=p>(</span>
<span class=s>"github.com/apache/beam/sdks/v2/go/pkg/beam/io/xlang/kafkaio"</span>
<span class=p>)</span>
@@ -4488,7 +4488,7 @@ functions as shortcuts for single, unnamed inputs/outputs or define a map for na
<span class=nx>outT</span> <span class=o>:=</span> <span class=nx>beam</span><span class=p>.</span><span class=nf>UnnamedOutput</span><span class=p>(</span><span class=nx>typex</span><span class=p>.</span><span class=nf>New</span><span class=p>(</span><span class=nx>reflectx</span><span class=p>.</span><span class=nx>String</span><span class=p>))</span>
<span class=nx>res</span> <span class=o>:=</span> <span class=nx>beam</span><span class=p>.</span><span class=nf>CrossLanguage</span><span class=p>(</span><span class=nx>s</span><span class=p>,</span> <span class=nx>urn</span><span class=p>,</span> <span class=nx>payload</span><span class=p>,</span> <span class=nx>expansionAddr</span><span class=p>,</span> <span class=nx>beam</span><span class=p>.</span><span class=nf>UnnamedInput</span><span class=p>(</span><span class=nx>inputPCol</spa [...]
</code></pre></div></li><li><p>After the job has been submitted to the Beam runner, shutdown the expansion service by
-terminating the expansion service process.</p></li></ol><h3 id=x-lang-transform-runner-support>13.3. Runner Support</h3><p>Currently, portable runners such as Flink, Spark, and the direct runner can be used with multi-language pipelines.</p><p>Dataflow supports multi-language pipelines through the Dataflow Runner v2 backend architecture.</p><h3 id=x-lang-transform-tips-troubleshooting>13.4 Tips and Troubleshooting</h3><p>For additional tips and troubleshooting information, see <a href=ht [...]
+terminating the expansion service process.</p></li></ol><h3 id=x-lang-transform-runner-support>13.3. Runner Support</h3><p>Currently, portable runners such as Flink, Spark, and the direct runner can be used with multi-language pipelines.</p><p>Dataflow supports multi-language pipelines through the Dataflow Runner v2 backend architecture.</p><h3 id=x-lang-transform-tips-troubleshooting>13.4 Tips and Troubleshooting</h3><p>For additional tips and troubleshooting information, see <a href=ht [...]
<a href=http://www.apache.org>The Apache Software Foundation</a>
| <a href=/privacy_policy>Privacy Policy</a>
| <a href=/feed.xml>RSS Feed</a><br><br>Apache Beam, Apache, Beam, the Beam logo, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation. All other products or name brands are trademarks of their respective holders, including The Apache Software Foundation.</div></div><div class="footer__cols__col footer__cols__col__logos"><div class=footer__cols__col--group><div class=footer__cols__col__logo><a href=https://github.com/apache/beam><im [...]
\ No newline at end of file
diff --git a/website/generated-content/sitemap.xml b/website/generated-content/sitemap.xml
index 7ec8a74c73d..79eba8e7b22 100644
--- a/website/generated-content/sitemap.xml
+++ b/website/generated-content/sitemap.xml
@@ -1 +1 @@
-<?xml version="1.0" encoding="utf-8" standalone="yes"?><urlset xmlns="http://www.sitemaps.org/schemas/sitemap/0.9" xmlns:xhtml="http://www.w3.org/1999/xhtml"><url><loc>/blog/go-2.40/</loc><lastmod>2022-07-06T14:03:32-04:00</lastmod></url><url><loc>/categories/blog/</loc><lastmod>2022-07-06T14:03:32-04:00</lastmod></url><url><loc>/blog/</loc><lastmod>2022-07-06T14:03:32-04:00</lastmod></url><url><loc>/categories/</loc><lastmod>2022-07-06T14:03:32-04:00</lastmod></url><url><loc>/categories [...]
\ No newline at end of file
+<?xml version="1.0" encoding="utf-8" standalone="yes"?><urlset xmlns="http://www.sitemaps.org/schemas/sitemap/0.9" xmlns:xhtml="http://www.w3.org/1999/xhtml"><url><loc>/blog/go-2.40/</loc><lastmod>2022-07-06T14:03:32-04:00</lastmod></url><url><loc>/categories/blog/</loc><lastmod>2022-07-06T14:03:32-04:00</lastmod></url><url><loc>/blog/</loc><lastmod>2022-07-06T14:03:32-04:00</lastmod></url><url><loc>/categories/</loc><lastmod>2022-07-06T14:03:32-04:00</lastmod></url><url><loc>/categories [...]
\ No newline at end of file