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 2019/10/09 21:18:00 UTC
[beam] branch asf-site updated: Publishing website 2019/10/09
21:17:46 at commit 603d68a
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 559edfa Publishing website 2019/10/09 21:17:46 at commit 603d68a
559edfa is described below
commit 559edfac7340426b92425925b4efb53e1f68d159
Author: jenkins <bu...@apache.org>
AuthorDate: Wed Oct 9 21:17:46 2019 +0000
Publishing website 2019/10/09 21:17:46 at commit 603d68a
---
.../get-started/mobile-gaming-example/index.html | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
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 ee6e589..23c0d20 100644
--- a/website/generated-content/get-started/mobile-gaming-example/index.html
+++ b/website/generated-content/get-started/mobile-gaming-example/index.html
@@ -445,7 +445,7 @@ looks more like what is depicted by the red squiggly line above the ideal line.<
<span class="o">}</span>
</code></pre>
</div>
-<div class="language-py highlighter-rouge"><pre class="highlight"><code><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="language-py highlighter-rouge"><pre class="highlight"><code><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="s">"""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>
@@ -466,7 +466,7 @@ looks more like what is depicted by the red squiggly line above the ideal line.<
<span class="c"># We use the save_main_session option because one or more DoFn's in this</span>
<span class="c"># 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>
@@ -700,7 +700,7 @@ logical windows based on when those scores occurred in event time.</em></p>
<span class="o">|</span> <span class="s">'ExtractAndSumScore'</span> <span class="o">>></span> <span class="n">ExtractAndSumScore</span><span class="p">(</span><span class="s">'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="s">"""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>
@@ -751,7 +751,7 @@ logical windows based on when those scores occurred in event time.</em></p>
<span class="c"># We use the save_main_session option because one or more DoFn's in this</span>
<span class="c"># 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="n">p</span> <span class="c"># pylint: disable=expression-not-assigned</span>