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 <bui...@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>