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/11 22:17:04 UTC
[beam] branch asf-site updated: Publishing website 2022/07/11 22:16:58 at commit 983e5c0
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 58ff967b053 Publishing website 2022/07/11 22:16:58 at commit 983e5c0
58ff967b053 is described below
commit 58ff967b053b8a3c92c94267717c3aab78a1dee2
Author: jenkins <bu...@apache.org>
AuthorDate: Mon Jul 11 22:16:58 2022 +0000
Publishing website 2022/07/11 22:16:58 at commit 983e5c0
---
website/generated-content/documentation/index.xml | 6 +++---
.../generated-content/documentation/programming-guide/index.html | 8 ++++----
website/generated-content/sitemap.xml | 2 +-
3 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/website/generated-content/documentation/index.xml b/website/generated-content/documentation/index.xml
index 9b91a7b9570..5c1862f31ac 100644
--- a/website/generated-content/documentation/index.xml
+++ b/website/generated-content/documentation/index.xml
@@ -4644,7 +4644,7 @@ a <code>PCollection</code>:</p>
</a>
<div class="highlight"><pre class="chroma"><code class="language-go" data-lang="go"><span class="nx">async</span> <span class="nx">function</span> <span class="nf">pipeline</span><span class="p">(</span><span class="nx">root</span><span class="p">:</span> <span class="nx">beam</span><span class="p">.</span><span class="nx">Root</span><span class="p">)</span> <span class="p">{</span>
<span class="c1">// Note that textio.ReadFromText is an AsyncPTransform.
-</span><span class="c1"></span> <span class="kd">const</span> <span class="nx">pcoll</span><span class="p">:</span> <span class="nx">PCollection</span><span class="p">&lt;</span><span class="kt">string</span><span class="p">&gt;</span> <span class="p">=</span> <span class="nx">await</span> <span class="nx">root</span><span class="p">.</span><span class="nf">asyncApply</span><span class="p">(</span>
+</span><span class="c1"></span> <span class="kd">const</span> <span class="nx">pcoll</span><span class="p">:</span> <span class="nx">PCollection</span><span class="p">&lt;</span><span class="kt">string</span><span class="p">&gt;</span> <span class="p">=</span> <span class="nx">await</span> <span class="nx">root</span><span class="p">.</span><span class="nf">applyAsync</span><span class="p">(</span>
<span class="nx">textio</span><span class="p">.</span><span class="nf">ReadFromText</span><span class="p">(</span><span class="s">&#34;path/to/text_pattern&#34;</span><span class="p">)</span>
<span class="p">);</span>
<span class="p">}</span></code></pre></div>
@@ -4885,7 +4885,7 @@ the transform itself as an argument, and the operation returns the output
<img src="/images/copy-icon.svg"/>
</a>
<div class="highlight"><pre class="chroma"><code class="language-typescript" data-lang="typescript"><span class="p">[</span><span class="nx">Output</span> <span class="nx">PCollection</span><span class="p">]</span> <span class="o">=</span> <span class="p">[</span><span class="nx">Input</span> <span class="nx">PCollection</span><span class="p">].</span><span class="nx">apply</span><span class="p">([</span><span [...]
-<span class="p">[</span><span class="nx">Output</span> <span class="nx">PCollection</span><span class="p">]</span> <span class="o">=</span> <span class="nx">await</span> <span class="p">[</span><span class="nx">Input</span> <span class="nx">PCollection</span><span class="p">].</span><span class="nx">asyncApply</span><span class="p">([</span><span class="nx">AsyncTransform</span><span class="p">])</span>
+<span class="p">[</span><span class="nx">Output</span> <span class="nx">PCollection</span><span class="p">]</span> <span class="o">=</span> <span class="nx">await</span> <span class="p">[</span><span class="nx">Input</span> <span class="nx">PCollection</span><span class="p">].</span><span class="nx">applyAsync</span><span class="p">([</span><span class="nx">AsyncTransform</span><span class="p">])</span>
</code></pre></div>
</div>
</div>
@@ -5014,7 +5014,7 @@ One can apply transforms to these composite types by wrapping them with
<code>beam.P({left: pcollA, right: pcollB}).apply(transformExpectingTwoPCollections)</code>.</p>
<p class="language-typescript">PTransforms come in two flavors, synchronous and asynchronous, depending on
whether their <em>application</em>* involves asynchronous invocations.
-An <code>AsyncTransform</code> must be applied with <code>asyncApply</code> and returns a <code>Promise</code>
+An <code>AsyncTransform</code> must be applied with <code>applyAsync</code> and returns a <code>Promise</code>
which must be awaited before further pipeline construction.</p>
<h3 id="core-beam-transforms">4.2. Core Beam transforms</h3>
<p>Beam provides the following core transforms, each of which represents a different
diff --git a/website/generated-content/documentation/programming-guide/index.html b/website/generated-content/documentation/programming-guide/index.html
index 5659b0353a3..69d86e968c1 100644
--- a/website/generated-content/documentation/programming-guide/index.html
+++ b/website/generated-content/documentation/programming-guide/index.html
@@ -230,7 +230,7 @@ a <code>PCollection</code>:</p><div class="language-java snippet"><div class="no
</span><span class=c1>// the method as is needed when calling all transforms.
</span><span class=c1></span><span class=nx>lines</span> <span class=o>:=</span> <span class=nx>textio</span><span class=p>.</span><span class=nf>Read</span><span class=p>(</span><span class=nx>scope</span><span class=p>,</span> <span class=s>"gs://some/inputData.txt"</span><span class=p>)</span></code></pre></div></div></div><div class="language-go snippet"><div class="notebook-skip code-snippet"><a class=copy type=button data-bs-toggle=tooltip data-bs-placement=bottom title="Co [...]
<span class=c1>// Note that textio.ReadFromText is an AsyncPTransform.
-</span><span class=c1></span> <span class=kd>const</span> <span class=nx>pcoll</span><span class=p>:</span> <span class=nx>PCollection</span><span class=p><</span><span class=kt>string</span><span class=p>></span> <span class=p>=</span> <span class=nx>await</span> <span class=nx>root</span><span class=p>.</span><span class=nf>asyncApply</span><span class=p>(</span>
+</span><span class=c1></span> <span class=kd>const</span> <span class=nx>pcoll</span><span class=p>:</span> <span class=nx>PCollection</span><span class=p><</span><span class=kt>string</span><span class=p>></span> <span class=p>=</span> <span class=nx>await</span> <span class=nx>root</span><span class=p>.</span><span class=nf>applyAsync</span><span class=p>(</span>
<span class=nx>textio</span><span class=p>.</span><span class=nf>ReadFromText</span><span class=p>(</span><span class=s>"path/to/text_pattern"</span><span class=p>)</span>
<span class=p>);</span>
<span class=p>}</span></code></pre></div></div></div><p>See the <a href=#pipeline-io>section on I/O</a> to learn more about how to read from the
@@ -371,7 +371,7 @@ Invoking multiple Beam transforms is similar to <em>method chaining</em>, but wi
slight difference: You apply the transform to the input <code>PCollection</code>, passing
the transform itself as an argument, and the operation returns the output
<code>PCollection</code>. This takes the general form:</p><div class="language-java snippet"><div class="notebook-skip code-snippet"><a class=copy type=button data-bs-toggle=tooltip data-bs-placement=bottom title="Copy to clipboard"><img src=/images/copy-icon.svg></a><div class=highlight><pre class=chroma><code class=language-java data-lang=java><span class=o>[</span><span class=n>Output</span> <span class=n>PCollection</span><span class=o>]</span> <span class=o>=</span> <span class=o>[< [...]
-<span class=p>[</span><span class=nx>Output</span> <span class=nx>PCollection</span><span class=p>]</span> <span class=o>=</span> <span class=nx>await</span> <span class=p>[</span><span class=nx>Input</span> <span class=nx>PCollection</span><span class=p>].</span><span class=nx>asyncApply</span><span class=p>([</span><span class=nx>AsyncTransform</span><span class=p>])</span>
+<span class=p>[</span><span class=nx>Output</span> <span class=nx>PCollection</span><span class=p>]</span> <span class=o>=</span> <span class=nx>await</span> <span class=p>[</span><span class=nx>Input</span> <span class=nx>PCollection</span><span class=p>].</span><span class=nx>applyAsync</span><span class=p>([</span><span class=nx>AsyncTransform</span><span class=p>])</span>
</code></pre></div></div></div><p class="language-java language-py language-typescript">Because Beam uses a generic <code>apply</code> method for <code>PCollection</code>, you can both chain
transforms sequentially and also apply transforms that contain other transforms
nested within (called <a href=#composite-transforms>composite transforms</a> in the Beam
@@ -416,7 +416,7 @@ One can apply transforms to these composite types by wrapping them with
<code>beam.P</code>, e.g.
<code>beam.P({left: pcollA, right: pcollB}).apply(transformExpectingTwoPCollections)</code>.</p><p class=language-typescript>PTransforms come in two flavors, synchronous and asynchronous, depending on
whether their <em>application</em>* involves asynchronous invocations.
-An <code>AsyncTransform</code> must be applied with <code>asyncApply</code> and returns a <code>Promise</code>
+An <code>AsyncTransform</code> must be applied with <code>applyAsync</code> and returns a <code>Promise</code>
which must be awaited before further pipeline construction.</p><h3 id=core-beam-transforms>4.2. Core Beam transforms</h3><p>Beam provides the following core transforms, each of which represents a different
processing paradigm:</p><ul><li><code>ParDo</code></li><li><code>GroupByKey</code></li><li><code>CoGroupByKey</code></li><li><code>Combine</code></li><li><code>Flatten</code></li><li><code>Partition</code></li></ul><p class=language-typescript>The Typescript SDK provides some of the most basic of these transforms
as methods on <code>PCollection</code> itself.</p><h4 id=pardo>4.2.1. ParDo</h4><p><code>ParDo</code> is a Beam transform for generic parallel processing. The <code>ParDo</code>
@@ -4824,7 +4824,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 fc3bf056da0..10a159c1baa 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