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/02/05 00:02:32 UTC
[beam] branch asf-site updated: Publishing website 2022/02/05 00:01:46 at commit 3e2979c
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 cff9bec Publishing website 2022/02/05 00:01:46 at commit 3e2979c
cff9bec is described below
commit cff9bec90e7f9b263ade1d4f6b4ea9b2f7a63924
Author: jenkins <bu...@apache.org>
AuthorDate: Sat Feb 5 00:01:47 2022 +0000
Publishing website 2022/02/05 00:01:46 at commit 3e2979c
---
website/generated-content/get-started/index.xml | 8 ++++----
.../get-started/mobile-gaming-example/index.html | 8 ++++----
2 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/website/generated-content/get-started/index.xml b/website/generated-content/get-started/index.xml
index e4cad29..162b278 100644
--- a/website/generated-content/get-started/index.xml
+++ b/website/generated-content/get-started/index.xml
@@ -191,7 +191,7 @@ looks more like what is depicted by the red squiggly line above the ideal line.&
<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-py" data-lang="py"><span class="k">def</span> <span class="nf">run</span><span class="p">(</span><span class="n">argv</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
+<div class="highlight"><pre class="chroma"><code class="language-py" data-lang="py"><span class="k">def</span> <span class="nf">run</span><span class="p">(</span><span class="n">argv</span><span class="o">=</span><span class="bp">None</span><span class="p">,</span> <span class="n">save_main_session</span><span class="o">=</span><span class="bp">True</span><span class="p">):</span>
<span class="s2">&#34;&#34;&#34;Main entry point; defines and runs the user_score pipeline.&#34;&#34;&#34;</span>
<span class="n">parser</span> <span class="o">=</span> <span class="n">argparse</span><span class="o">.</span><span class="n">ArgumentParser</span><span class="p">()</span>
<span class="c1"># The default maps to two large Google Cloud Storage files (each ~12GB)</span>
@@ -207,7 +207,7 @@ looks more like what is depicted by the red squiggly line above the ideal line.&
<span class="n">options</span> <span class="o">=</span> <span class="n">PipelineOptions</span><span class="p">(</span><span class="n">pipeline_args</span><span class="p">)</span>
<span class="c1"># We use the save_main_session option because one or more DoFn&#39;s in this</span>
<span class="c1"># workflow rely on global context (e.g., a module imported at module level).</span>
-<span class="n">options</span><span class="o">.</span><span class="n">view_as</span><span class="p">(</span><span class="n">SetupOptions</span><span class="p">)</span><span class="o">.</span><span class="n">save_main_session</span> <span class="o">=</span> <span class="bp">True</span>
+<span class="n">options</span><span class="o">.</span><span class="n">view_as</span><span class="p">(</span><span class="n">SetupOptions</span><span class="p">)</span><span class="o">.</span><span class="n">save_main_session</span> <span class="o">=</span> <span class="n">save_main_session</span>
<span class="k">with</span> <span class="n">beam</span><span class="o">.</span><span class="n">Pipeline</span><span class="p">(</span><span class="n">options</span><span class="o">=</span><span class="n">options</span><span class="p">)</span> <span class="k">as</span> <span class="n">p</span><span class="p">:</span>
<span class="k">def</span> <span class="nf">format_user_score_sums</span><span class="p">(</span><span class="n">user_score</span><span class="p">):</span>
<span class="p">(</span><span class="n">user</span><span class="p">,</span> <span class="n">score</span><span class="p">)</span> <span class="o">=</span> <span class="n">user_score</span>
@@ -425,7 +425,7 @@ logical windows based on when those scores occurred in event time.</em></p
<span class="c1"># [END add_timestamp_and_window]</span>
<span class="c1"># Extract and sum teamname/score pairs from the event data.</span>
<span class="o">|</span> <span class="s1">&#39;ExtractAndSumScore&#39;</span> <span class="o">&gt;&gt;</span> <span class="n">ExtractAndSumScore</span><span class="p">(</span><span class="s1">&#39;team&#39;</span><span class="p">))</span>
-<span class="k">def</span> <span class="nf">run</span><span class="p">(</span><span class="n">argv</span><span class="o">=</span><span class="bp">None</span><span class="p">):</span>
+<span class="k">def</span> <span class="nf">run</span><span class="p">(</span><span class="n">argv</span><span class="o">=</span><span class="bp">None</span><span class="p">,</span> <span class="n">save_main_session</span><span class="o">=</span><span class="bp">True</span><span class="p">):</span>
<span class="s2">&#34;&#34;&#34;Main entry point; defines and runs the hourly_team_score pipeline.&#34;&#34;&#34;</span>
<span class="n">parser</span> <span class="o">=</span> <span class="n">argparse</span><span class="o">.</span><span class="n">ArgumentParser</span><span class="p">()</span>
<span class="c1"># The default maps to two large Google Cloud Storage files (each ~12GB)</span>
@@ -477,7 +477,7 @@ logical windows based on when those scores occurred in event time.</em></p
<span class="n">sys</span><span class="o">.</span><span class="n">exit</span><span class="p">(</span><span class="mi">1</span><span class="p">)</span>
<span class="c1"># We use the save_main_session option because one or more DoFn&#39;s in this</span>
<span class="c1"># workflow rely on global context (e.g., a module imported at module level).</span>
-<span class="n">options</span><span class="o">.</span><span class="n">view_as</span><span class="p">(</span><span class="n">SetupOptions</span><span class="p">)</span><span class="o">.</span><span class="n">save_main_session</span> <span class="o">=</span> <span class="bp">True</span>
+<span class="n">options</span><span class="o">.</span><span class="n">view_as</span><span class="p">(</span><span class="n">SetupOptions</span><span class="p">)</span><span class="o">.</span><span class="n">save_main_session</span> <span class="o">=</span> <span class="n">save_main_session</span>
<span class="k">with</span> <span class="n">beam</span><span class="o">.</span><span class="n">Pipeline</span><span class="p">(</span><span class="n">options</span><span class="o">=</span><span class="n">options</span><span class="p">)</span> <span class="k">as</span> <span class="n">p</span><span class="p">:</span>
<span class="p">(</span> <span class="c1"># pylint: disable=expression-not-assigned</span>
<span class="n">p</span>
diff --git a/website/generated-content/get-started/mobile-gaming-example/index.html b/website/generated-content/get-started/mobile-gaming-example/index.html
index fa9a9a5..8e76ce7 100644
--- a/website/generated-content/get-started/mobile-gaming-example/index.html
+++ b/website/generated-content/get-started/mobile-gaming-example/index.html
@@ -73,7 +73,7 @@ looks more like what is depicted by the red squiggly line above the ideal line.<
<span class=c1>// Run the batch pipeline.
</span><span class=c1></span> <span class=n>pipeline</span><span class=o>.</span><span class=na>run</span><span class=o>().</span><span class=na>waitUntilFinish</span><span class=o>();</span>
-<span class=o>}</span></code></pre></div></div></div><div class="language-py 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-py data-lang=py><span class=k>def</span> <span class=nf>run</span><span class=p>(</span><span class=n>argv</span><span class=o>=</span><span class=bp>None</span><span clas [...]
+<span class=o>}</span></code></pre></div></div></div><div class="language-py 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-py data-lang=py><span class=k>def</span> <span class=nf>run</span><span class=p>(</span><span class=n>argv</span><span class=o>=</span><span class=bp>None</span><span clas [...]
<span class=s2>"""Main entry point; defines and runs the user_score pipeline."""</span>
<span class=n>parser</span> <span class=o>=</span> <span class=n>argparse</span><span class=o>.</span><span class=n>ArgumentParser</span><span class=p>()</span>
@@ -93,7 +93,7 @@ looks more like what is depicted by the red squiggly line above the ideal line.<
<span class=c1># We use the save_main_session option because one or more DoFn's in this</span>
<span class=c1># workflow rely on global context (e.g., a module imported at module level).</span>
- <span class=n>options</span><span class=o>.</span><span class=n>view_as</span><span class=p>(</span><span class=n>SetupOptions</span><span class=p>)</span><span class=o>.</span><span class=n>save_main_session</span> <span class=o>=</span> <span class=bp>True</span>
+ <span class=n>options</span><span class=o>.</span><span class=n>view_as</span><span class=p>(</span><span class=n>SetupOptions</span><span class=p>)</span><span class=o>.</span><span class=n>save_main_session</span> <span class=o>=</span> <span class=n>save_main_session</span>
<span class=k>with</span> <span class=n>beam</span><span class=o>.</span><span class=n>Pipeline</span><span class=p>(</span><span class=n>options</span><span class=o>=</span><span class=n>options</span><span class=p>)</span> <span class=k>as</span> <span class=n>p</span><span class=p>:</span>
@@ -218,7 +218,7 @@ logical windows based on when those scores occurred in event time.</em></p><p>No
<span class=o>|</span> <span class=s1>'ExtractAndSumScore'</span> <span class=o>>></span> <span class=n>ExtractAndSumScore</span><span class=p>(</span><span class=s1>'team'</span><span class=p>))</span>
-<span class=k>def</span> <span class=nf>run</span><span class=p>(</span><span class=n>argv</span><span class=o>=</span><span class=bp>None</span><span class=p>):</span>
+<span class=k>def</span> <span class=nf>run</span><span class=p>(</span><span class=n>argv</span><span class=o>=</span><span class=bp>None</span><span class=p>,</span> <span class=n>save_main_session</span><span class=o>=</span><span class=bp>True</span><span class=p>):</span>
<span class=s2>"""Main entry point; defines and runs the hourly_team_score pipeline."""</span>
<span class=n>parser</span> <span class=o>=</span> <span class=n>argparse</span><span class=o>.</span><span class=n>ArgumentParser</span><span class=p>()</span>
@@ -275,7 +275,7 @@ logical windows based on when those scores occurred in event time.</em></p><p>No
<span class=c1># We use the save_main_session option because one or more DoFn's in this</span>
<span class=c1># workflow rely on global context (e.g., a module imported at module level).</span>
- <span class=n>options</span><span class=o>.</span><span class=n>view_as</span><span class=p>(</span><span class=n>SetupOptions</span><span class=p>)</span><span class=o>.</span><span class=n>save_main_session</span> <span class=o>=</span> <span class=bp>True</span>
+ <span class=n>options</span><span class=o>.</span><span class=n>view_as</span><span class=p>(</span><span class=n>SetupOptions</span><span class=p>)</span><span class=o>.</span><span class=n>save_main_session</span> <span class=o>=</span> <span class=n>save_main_session</span>
<span class=k>with</span> <span class=n>beam</span><span class=o>.</span><span class=n>Pipeline</span><span class=p>(</span><span class=n>options</span><span class=o>=</span><span class=n>options</span><span class=p>)</span> <span class=k>as</span> <span class=n>p</span><span class=p>:</span>
<span class=p>(</span> <span class=c1># pylint: disable=expression-not-assigned</span>