[beam] branch asf-site updated: Publishing website 2021/11/11 00:03:25 at commit 1a572cf

[git-site-role]

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 0e24f7f  Publishing website 2021/11/11 00:03:25 at commit 1a572cf
0e24f7f is described below

commit 0e24f7f8eaeb27e395eb21bbc1a7e36dafc508b2
Author: jenkins <bui...@apache.org>
AuthorDate: Thu Nov 11 00:03:25 2021 +0000

    Publishing website 2021/11/11 00:03:25 at commit 1a572cf
---
 website/generated-content/documentation/index.xml  | 22 ++++++++++----------
 .../documentation/programming-guide/index.html     | 24 +++++++++++-----------
 website/generated-content/sitemap.xml              |  2 +-
 3 files changed, 24 insertions(+), 24 deletions(-)

diff --git a/website/generated-content/documentation/index.xml 
b/website/generated-content/documentation/index.xml
index 3fd4cca..9fd2854 100644
--- a/website/generated-content/documentation/index.xml
+++ b/website/generated-content/documentation/index.xml
@@ -9193,7 +9193,7 @@ timestamps attached to the data elements. The watermark 
is a global progress
 metric, and is Beam&amp;rsquo;s notion of input completeness within your 
pipeline at any
 given point. &lt;span 
class="language-java">&lt;code>AfterWatermark.pastEndOfWindow()&lt;/code>&lt;/span>
 &lt;span class="language-py">&lt;code>AfterWatermark&lt;/code>&lt;/span>
-&lt;span 
class="language-go">&lt;code>window.AfterEndOfWindow&lt;/code>&lt;/span> 
&lt;em>only&lt;/em> fires when the
+&lt;span 
class="language-go">&lt;code>trigger.AfterEndOfWindow&lt;/code>&lt;/span> 
&lt;em>only&lt;/em> fires when the
 watermark passes the end of the window.&lt;/p>
 &lt;p>In addition, you can configure triggers that fire if your pipeline 
receives data
 before or after the end of the window.&lt;/p>
@@ -9229,10 +9229,10 @@ firings:&lt;/p>
 &lt;a class="copy" type="button" data-bs-toggle="tooltip" 
data-bs-placement="bottom" title="Copy to clipboard">
 &lt;img src="/images/copy-icon.svg"/>
 &lt;/a>
-&lt;div class="highlight">&lt;pre class="chroma">&lt;code class="language-go" 
data-lang="go">&lt;span class="nx">trigger&lt;/span> &lt;span 
class="o">:=&lt;/span> &lt;span class="nx">window&lt;/span>&lt;span 
class="p">.&lt;/span>&lt;span 
class="nf">TriggerAfterEndOfWindow&lt;/span>&lt;span class="p">().&lt;/span>
-&lt;span class="nf">EarlyFiring&lt;/span>&lt;span 
class="p">(&lt;/span>&lt;span class="nx">window&lt;/span>&lt;span 
class="p">.&lt;/span>&lt;span 
class="nf">TriggerAfterProcessingTime&lt;/span>&lt;span class="p">().&lt;/span>
+&lt;div class="highlight">&lt;pre class="chroma">&lt;code class="language-go" 
data-lang="go">&lt;span class="nx">trigger&lt;/span> &lt;span 
class="o">:=&lt;/span> &lt;span class="nx">trigger&lt;/span>&lt;span 
class="p">.&lt;/span>&lt;span class="nf">AfterEndOfWindow&lt;/span>&lt;span 
class="p">().&lt;/span>
+&lt;span class="nf">EarlyFiring&lt;/span>&lt;span 
class="p">(&lt;/span>&lt;span class="nx">trigger&lt;/span>&lt;span 
class="p">.&lt;/span>&lt;span class="nf">AfterProcessingTime&lt;/span>&lt;span 
class="p">().&lt;/span>
 &lt;span class="nf">PlusDelay&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="mi">60&lt;/span> &lt;span class="o">*&lt;/span> &lt;span 
class="nx">time&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nx">Second&lt;/span>&lt;span class="p">)).&lt;/span>
-&lt;span class="nf">LateFiring&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="nx">window&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">TriggerRepeat&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="nx">window&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">TriggerAfterCount&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="mi">1&lt;/span>&lt;span 
class="p">)))&lt;/span>&lt;/code>&lt;/pre>&lt;/div>
+&lt;span class="nf">LateFiring&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="nx">trigger&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">Repeat&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="nx">trigger&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">AfterCount&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="mi">1&lt;/span>&lt;span 
class="p">)))&lt;/span>&lt;/code>&lt;/pre>&lt;/div>
 &lt;/div>
 &lt;/div>
 &lt;h4 id="default-trigger">9.1.1. Default trigger&lt;/h4>
@@ -9248,7 +9248,7 @@ modifying this behavior.&lt;/p>
 &lt;p>The &lt;code>AfterProcessingTime&lt;/code> trigger operates on 
&lt;em>processing time&lt;/em>. For example,
 the &lt;span 
class="language-java">&lt;code>AfterProcessingTime.pastFirstElementInPane()&lt;/code>&lt;/span>
 &lt;span class="language-py">&lt;code>AfterProcessingTime&lt;/code>&lt;/span>
-&lt;span 
class="language-go">&lt;code>window.TriggerAfterProcessingTime()&lt;/code>&lt;/span>
 trigger emits a window
+&lt;span 
class="language-go">&lt;code>trigger.AfterProcessingTime()&lt;/code>&lt;/span> 
trigger emits a window
 after a certain amount of processing time has passed since data was received.
 The processing time is determined by the system clock, rather than the data
 element&amp;rsquo;s timestamp.&lt;/p>
@@ -9259,14 +9259,14 @@ window.&lt;/p>
 &lt;p>Beam provides one data-driven trigger,
 &lt;span 
class="language-java">&lt;code>AfterPane.elementCountAtLeast()&lt;/code>&lt;/span>
 &lt;span class="language-py">&lt;code>AfterCount&lt;/code>&lt;/span>
-&lt;span 
class="language-go">&lt;code>window.TriggerAfterCount()&lt;/code>&lt;/span>. 
This trigger works on an element
+&lt;span 
class="language-go">&lt;code>trigger.AfterCount()&lt;/code>&lt;/span>. This 
trigger works on an element
 count; it fires after the current pane has collected at least &lt;em>N&lt;/em> 
elements. This
 allows a window to emit early results (before all the data has accumulated),
 which can be particularly useful if you are using a single global 
window.&lt;/p>
 &lt;p>It is important to note that if, for example, you specify
 &lt;span 
class="language-java">&lt;code>.elementCountAtLeast(50)&lt;/code>&lt;/span>
 &lt;span class="language-py">AfterCount(50)&lt;/span>
-&lt;span 
class="language-go">&lt;code>window.TriggerAfterCount(50)&lt;/code>&lt;/span> 
and only 32 elements arrive,
+&lt;span 
class="language-go">&lt;code>trigger.AfterCount(50)&lt;/code>&lt;/span> and 
only 32 elements arrive,
 those 32 elements sit around forever. If the 32 elements are important to you,
 consider using &lt;a href="#composite-triggers">composite triggers&lt;/a> to 
combine multiple
 conditions. This allows you to specify multiple firing conditions such as 
&amp;ldquo;fire
@@ -9321,7 +9321,7 @@ The &lt;code>beam.AccumulationMode&lt;/code> parameter 
sets the window&amp;rsquo
 &lt;/a>
 &lt;div class="highlight">&lt;pre class="chroma">&lt;code class="language-go" 
data-lang="go">&lt;span class="nx">windowedItems&lt;/span> &lt;span 
class="o">:=&lt;/span> &lt;span class="nx">beam&lt;/span>&lt;span 
class="p">.&lt;/span>&lt;span class="nf">WindowInto&lt;/span>&lt;span 
class="p">(&lt;/span>&lt;span class="nx">s&lt;/span>&lt;span 
class="p">,&lt;/span>
 &lt;span class="nx">window&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">NewFixedWindows&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="mi">1&lt;/span>&lt;span class="o">*&lt;/span>&lt;span 
class="nx">time&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nx">Minute&lt;/span>&lt;span class="p">),&lt;/span> &lt;span 
class="nx">pcollection&lt;/span>&lt;span class="p">,&lt;/span>
-&lt;span class="nx">beam&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">Trigger&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="nx">window&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">TriggerAfterProcessingTime&lt;/span>&lt;span class="p">().&lt;/span>
+&lt;span class="nx">beam&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">Trigger&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="nx">trigger&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">AfterProcessingTime&lt;/span>&lt;span class="p">().&lt;/span>
 &lt;span class="nf">PlusDelay&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="mi">1&lt;/span>&lt;span class="o">*&lt;/span>&lt;span 
class="nx">time&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nx">Minute&lt;/span>&lt;span class="p">)),&lt;/span>
 &lt;span class="nx">beam&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">AllowedLateness&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="mi">30&lt;/span>&lt;span class="o">*&lt;/span>&lt;span 
class="nx">time&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nx">Minute&lt;/span>&lt;span class="p">),&lt;/span>
 &lt;span class="nx">beam&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">PanesDiscard&lt;/span>&lt;span class="p">(),&lt;/span>
@@ -9414,7 +9414,7 @@ when you set your windowing function:&lt;/p>
 &lt;/a>
 &lt;div class="highlight">&lt;pre class="chroma">&lt;code class="language-go" 
data-lang="go">&lt;span class="nx">allowedToBeLateItems&lt;/span> &lt;span 
class="o">:=&lt;/span> &lt;span class="nx">beam&lt;/span>&lt;span 
class="p">.&lt;/span>&lt;span class="nf">WindowInto&lt;/span>&lt;span 
class="p">(&lt;/span>&lt;span class="nx">s&lt;/span>&lt;span 
class="p">,&lt;/span>
 &lt;span class="nx">window&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">NewFixedWindows&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="mi">1&lt;/span>&lt;span class="o">*&lt;/span>&lt;span 
class="nx">time&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nx">Minute&lt;/span>&lt;span class="p">),&lt;/span> &lt;span 
class="nx">pcollection&lt;/span>&lt;span class="p">,&lt;/span>
-&lt;span class="nx">beam&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">Trigger&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="nx">window&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">TriggerAfterProcessingTime&lt;/span>&lt;span class="p">().&lt;/span>
+&lt;span class="nx">beam&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">Trigger&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="nx">trigger&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">AfterProcessingTime&lt;/span>&lt;span class="p">().&lt;/span>
 &lt;span class="nf">PlusDelay&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="mi">1&lt;/span>&lt;span class="o">*&lt;/span>&lt;span 
class="nx">time&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nx">Minute&lt;/span>&lt;span class="p">)),&lt;/span>
 &lt;span class="nx">beam&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">AllowedLateness&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="mi">30&lt;/span>&lt;span class="o">*&lt;/span>&lt;span 
class="nx">time&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nx">Minute&lt;/span>&lt;span class="p">),&lt;/span>
 &lt;span class="p">)&lt;/span>&lt;/code>&lt;/pre>&lt;/div>
@@ -9517,8 +9517,8 @@ trigger stops executing&lt;/li>
 &lt;/a>
 &lt;div class="highlight">&lt;pre class="chroma">&lt;code class="language-go" 
data-lang="go">&lt;span class="nx">compositeTriggerItems&lt;/span> &lt;span 
class="o">:=&lt;/span> &lt;span class="nx">beam&lt;/span>&lt;span 
class="p">.&lt;/span>&lt;span class="nf">WindowInto&lt;/span>&lt;span 
class="p">(&lt;/span>&lt;span class="nx">s&lt;/span>&lt;span 
class="p">,&lt;/span>
 &lt;span class="nx">window&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">NewFixedWindows&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="mi">1&lt;/span>&lt;span class="o">*&lt;/span>&lt;span 
class="nx">time&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nx">Minute&lt;/span>&lt;span class="p">),&lt;/span> &lt;span 
class="nx">pcollection&lt;/span>&lt;span class="p">,&lt;/span>
-&lt;span class="nx">beam&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">Trigger&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="nx">window&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">TriggerAfterEndOfWindow&lt;/span>&lt;span class="p">().&lt;/span>
-&lt;span class="nf">LateFiring&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="nx">window&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">TriggerAfterProcessingTime&lt;/span>&lt;span class="p">().&lt;/span>
+&lt;span class="nx">beam&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">Trigger&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="nx">trigger&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">AfterEndOfWindow&lt;/span>&lt;span class="p">().&lt;/span>
+&lt;span class="nf">LateFiring&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="nx">trigger&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">AfterProcessingTime&lt;/span>&lt;span class="p">().&lt;/span>
 &lt;span class="nf">PlusDelay&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="mi">10&lt;/span>&lt;span class="o">*&lt;/span>&lt;span 
class="nx">time&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nx">Minute&lt;/span>&lt;span class="p">))),&lt;/span>
 &lt;span class="nx">beam&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nf">AllowedLateness&lt;/span>&lt;span class="p">(&lt;/span>&lt;span 
class="mi">2&lt;/span>&lt;span class="o">*&lt;/span>&lt;span 
class="mi">24&lt;/span>&lt;span class="o">*&lt;/span>&lt;span 
class="nx">time&lt;/span>&lt;span class="p">.&lt;/span>&lt;span 
class="nx">Hour&lt;/span>&lt;span class="p">),&lt;/span>
 &lt;span class="p">)&lt;/span>&lt;/code>&lt;/pre>&lt;/div>
diff --git 
a/website/generated-content/documentation/programming-guide/index.html 
b/website/generated-content/documentation/programming-guide/index.html
index 1756efa..67d2a58 100644
--- a/website/generated-content/documentation/programming-guide/index.html
+++ b/website/generated-content/documentation/programming-guide/index.html
@@ -2756,7 +2756,7 @@ timestamps attached to the data elements. The watermark 
is a global progress
 metric, and is Beam&rsquo;s notion of input completeness within your pipeline 
at any
 given point. <span 
class=language-java><code>AfterWatermark.pastEndOfWindow()</code></span>
 <span class=language-py><code>AfterWatermark</code></span>
-<span class=language-go><code>window.AfterEndOfWindow</code></span> 
<em>only</em> fires when the
+<span class=language-go><code>trigger.AfterEndOfWindow</code></span> 
<em>only</em> fires when the
 watermark passes the end of the window.</p><p>In addition, you can configure 
triggers that fire if your pipeline receives data
 before or after the end of the window.</p><p>The following example shows a 
billing scenario, and uses both early and late
 firings:</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=c1>// Create a bill at the end 
of the month.
@@ -2768,10 +2768,10 @@ firings:</p><div class="language-java snippet"><div 
class="notebook-skip code-sn
               <span class=o>.</span><span class=na>plusDuration</span><span 
class=o>(</span><span class=n>Duration</span><span class=o>.</span><span 
class=na>standardMinutes</span><span class=o>(</span><span 
class=n>1</span><span class=o>))</span>
       <span class=c1>// Fire on any late data so the bill can be corrected.
 </span><span class=c1></span>      <span class=o>.</span><span 
class=na>withLateFirings</span><span class=o>(</span><span 
class=n>AfterPane</span><span class=o>.</span><span 
class=na>elementCountAtLeast</span><span class=o>(</span><span 
class=n>1</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=/im [...]
-    <span class=n>early</span><span class=o>=</span><span 
class=n>AfterProcessingTime</span><span class=p>(</span><span 
class=n>delay</span><span class=o>=</span><span class=mi>1</span> <span 
class=o>*</span> <span class=mi>60</span><span class=p>),</span> <span 
class=n>late</span><span class=o>=</span><span class=n>AfterCount</span><span 
class=p>(</span><span class=mi>1</span><span 
class=p>))</span></code></pre></div></div></div><div class="language-go 
snippet"><div class="notebook-skip [...]
-       <span class=nf>EarlyFiring</span><span class=p>(</span><span 
class=nx>window</span><span class=p>.</span><span 
class=nf>TriggerAfterProcessingTime</span><span class=p>().</span>
+    <span class=n>early</span><span class=o>=</span><span 
class=n>AfterProcessingTime</span><span class=p>(</span><span 
class=n>delay</span><span class=o>=</span><span class=mi>1</span> <span 
class=o>*</span> <span class=mi>60</span><span class=p>),</span> <span 
class=n>late</span><span class=o>=</span><span class=n>AfterCount</span><span 
class=p>(</span><span class=mi>1</span><span 
class=p>))</span></code></pre></div></div></div><div class="language-go 
snippet"><div class="notebook-skip [...]
+       <span class=nf>EarlyFiring</span><span class=p>(</span><span 
class=nx>trigger</span><span class=p>.</span><span 
class=nf>AfterProcessingTime</span><span class=p>().</span>
                <span class=nf>PlusDelay</span><span class=p>(</span><span 
class=mi>60</span> <span class=o>*</span> <span class=nx>time</span><span 
class=p>.</span><span class=nx>Second</span><span class=p>)).</span>
-       <span class=nf>LateFiring</span><span class=p>(</span><span 
class=nx>window</span><span class=p>.</span><span 
class=nf>TriggerRepeat</span><span class=p>(</span><span 
class=nx>window</span><span class=p>.</span><span 
class=nf>TriggerAfterCount</span><span class=p>(</span><span 
class=mi>1</span><span class=p>)))</span></code></pre></div></div></div><h4 
id=default-trigger>9.1.1. Default trigger</h4><p>The default trigger for a 
<code>PCollection</code> is based on event time, and emits the
+       <span class=nf>LateFiring</span><span class=p>(</span><span 
class=nx>trigger</span><span class=p>.</span><span class=nf>Repeat</span><span 
class=p>(</span><span class=nx>trigger</span><span class=p>.</span><span 
class=nf>AfterCount</span><span class=p>(</span><span class=mi>1</span><span 
class=p>)))</span></code></pre></div></div></div><h4 id=default-trigger>9.1.1. 
Default trigger</h4><p>The default trigger for a <code>PCollection</code> is 
based on event time, and emits the
 results of the window when the Beam&rsquo;s watermark passes the end of the 
window,
 and then fires each time late data arrives.</p><p>However, if you are using 
both the default windowing configuration and the
 default trigger, the default trigger emits exactly once, and late data is
@@ -2780,7 +2780,7 @@ lateness value of 0. See the Handling Late Data section 
for information about
 modifying this behavior.</p><h3 id=processing-time-triggers>9.2. Processing 
time triggers</h3><p>The <code>AfterProcessingTime</code> trigger operates on 
<em>processing time</em>. For example,
 the <span 
class=language-java><code>AfterProcessingTime.pastFirstElementInPane()</code></span>
 <span class=language-py><code>AfterProcessingTime</code></span>
-<span 
class=language-go><code>window.TriggerAfterProcessingTime()</code></span> 
trigger emits a window
+<span class=language-go><code>trigger.AfterProcessingTime()</code></span> 
trigger emits a window
 after a certain amount of processing time has passed since data was received.
 The processing time is determined by the system clock, rather than the data
 element&rsquo;s timestamp.</p><p>The <code>AfterProcessingTime</code> trigger 
is useful for triggering early results from a
@@ -2788,13 +2788,13 @@ window, particularly a window with a large time frame 
such as a single global
 window.</p><h3 id=data-driven-triggers>9.3. Data-driven triggers</h3><p>Beam 
provides one data-driven trigger,
 <span class=language-java><code>AfterPane.elementCountAtLeast()</code></span>
 <span class=language-py><code>AfterCount</code></span>
-<span class=language-go><code>window.TriggerAfterCount()</code></span>. This 
trigger works on an element
+<span class=language-go><code>trigger.AfterCount()</code></span>. This trigger 
works on an element
 count; it fires after the current pane has collected at least <em>N</em> 
elements. This
 allows a window to emit early results (before all the data has accumulated),
 which can be particularly useful if you are using a single global 
window.</p><p>It is important to note that if, for example, you specify
 <span class=language-java><code>.elementCountAtLeast(50)</code></span>
 <span class=language-py>AfterCount(50)</span>
-<span class=language-go><code>window.TriggerAfterCount(50)</code></span> and 
only 32 elements arrive,
+<span class=language-go><code>trigger.AfterCount(50)</code></span> and only 32 
elements arrive,
 those 32 elements sit around forever. If the 32 elements are important to you,
 consider using <a href=#composite-triggers>composite triggers</a> to combine 
multiple
 conditions. This allows you to specify multiple firing conditions such as 
&ldquo;fire
@@ -2822,7 +2822,7 @@ The <code>beam.AccumulationMode</code> parameter sets the 
window&rsquo;s <strong
     <span class=n>trigger</span><span class=o>=</span><span 
class=n>AfterProcessingTime</span><span class=p>(</span><span class=mi>1</span> 
<span class=o>*</span> <span class=mi>60</span><span class=p>),</span>
     <span class=n>accumulation_mode</span><span class=o>=</span><span 
class=n>AccumulationMode</span><span class=o>.</span><span 
class=n>DISCARDING</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="Copy to clipboard"><img 
src=/images/copy-icon.svg></a><div class=highlight><pre class=chroma><code 
class=language-go data-lang=go>< [...]
        <span class=nx>window</span><span class=p>.</span><span 
class=nf>NewFixedWindows</span><span class=p>(</span><span 
class=mi>1</span><span class=o>*</span><span class=nx>time</span><span 
class=p>.</span><span class=nx>Minute</span><span class=p>),</span> <span 
class=nx>pcollection</span><span class=p>,</span>
-       <span class=nx>beam</span><span class=p>.</span><span 
class=nf>Trigger</span><span class=p>(</span><span class=nx>window</span><span 
class=p>.</span><span class=nf>TriggerAfterProcessingTime</span><span 
class=p>().</span>
+       <span class=nx>beam</span><span class=p>.</span><span 
class=nf>Trigger</span><span class=p>(</span><span class=nx>trigger</span><span 
class=p>.</span><span class=nf>AfterProcessingTime</span><span 
class=p>().</span>
                <span class=nf>PlusDelay</span><span class=p>(</span><span 
class=mi>1</span><span class=o>*</span><span class=nx>time</span><span 
class=p>.</span><span class=nx>Minute</span><span class=p>)),</span>
        <span class=nx>beam</span><span class=p>.</span><span 
class=nf>AllowedLateness</span><span class=p>(</span><span 
class=mi>30</span><span class=o>*</span><span class=nx>time</span><span 
class=p>.</span><span class=nx>Minute</span><span class=p>),</span>
        <span class=nx>beam</span><span class=p>.</span><span 
class=nf>PanesDiscard</span><span class=p>(),</span>
@@ -2872,7 +2872,7 @@ when you set your windowing function:</p><div 
class="language-java snippet"><div
             <span class=n>allowed_lateness</span><span class=o>=</span><span 
class=mi>1800</span><span class=p>)</span> <span class=c1># 30 minutes</span>
      <span class=o>|</span> <span 
class=o>...</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="Copy to clipboard"><img 
src=/images/copy-icon.svg></a><div class=highlight><pre class=chroma><code 
class=language-go data-lang=go><span class=nx>allowedToBeLateItems</span> <span 
class=o>:=</span> <span class=nx>beam</span><span class=p>.</span><span clas 
[...]
        <span class=nx>window</span><span class=p>.</span><span 
class=nf>NewFixedWindows</span><span class=p>(</span><span 
class=mi>1</span><span class=o>*</span><span class=nx>time</span><span 
class=p>.</span><span class=nx>Minute</span><span class=p>),</span> <span 
class=nx>pcollection</span><span class=p>,</span>
-       <span class=nx>beam</span><span class=p>.</span><span 
class=nf>Trigger</span><span class=p>(</span><span class=nx>window</span><span 
class=p>.</span><span class=nf>TriggerAfterProcessingTime</span><span 
class=p>().</span>
+       <span class=nx>beam</span><span class=p>.</span><span 
class=nf>Trigger</span><span class=p>(</span><span class=nx>trigger</span><span 
class=p>.</span><span class=nf>AfterProcessingTime</span><span 
class=p>().</span>
                <span class=nf>PlusDelay</span><span class=p>(</span><span 
class=mi>1</span><span class=o>*</span><span class=nx>time</span><span 
class=p>.</span><span class=nx>Minute</span><span class=p>)),</span>
        <span class=nx>beam</span><span class=p>.</span><span 
class=nf>AllowedLateness</span><span class=p>(</span><span 
class=mi>30</span><span class=o>*</span><span class=nx>time</span><span 
class=p>.</span><span class=nx>Minute</span><span class=p>),</span>
 <span class=p>)</span></code></pre></div></div></div><p>This allowed lateness 
propagates to all <code>PCollection</code>s derived as a result of
@@ -2916,8 +2916,8 @@ trigger stops executing</li></ul></p><div 
class="language-java snippet"><div cla
     <span class=n>allowed_lateness</span><span class=o>=</span><span 
class=mi>10</span><span class=p>,</span>
     <span class=n>accumulation_mode</span><span class=o>=</span><span 
class=n>AccumulationMode</span><span class=o>.</span><span 
class=n>DISCARDING</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="Copy to clipboard"><img 
src=/images/copy-icon.svg></a><div class=highlight><pre class=chroma><code 
class=language-go data-lang=go>< [...]
        <span class=nx>window</span><span class=p>.</span><span 
class=nf>NewFixedWindows</span><span class=p>(</span><span 
class=mi>1</span><span class=o>*</span><span class=nx>time</span><span 
class=p>.</span><span class=nx>Minute</span><span class=p>),</span> <span 
class=nx>pcollection</span><span class=p>,</span>
-       <span class=nx>beam</span><span class=p>.</span><span 
class=nf>Trigger</span><span class=p>(</span><span class=nx>window</span><span 
class=p>.</span><span class=nf>TriggerAfterEndOfWindow</span><span 
class=p>().</span>
-               <span class=nf>LateFiring</span><span class=p>(</span><span 
class=nx>window</span><span class=p>.</span><span 
class=nf>TriggerAfterProcessingTime</span><span class=p>().</span>
+       <span class=nx>beam</span><span class=p>.</span><span 
class=nf>Trigger</span><span class=p>(</span><span class=nx>trigger</span><span 
class=p>.</span><span class=nf>AfterEndOfWindow</span><span class=p>().</span>
+               <span class=nf>LateFiring</span><span class=p>(</span><span 
class=nx>trigger</span><span class=p>.</span><span 
class=nf>AfterProcessingTime</span><span class=p>().</span>
                        <span class=nf>PlusDelay</span><span 
class=p>(</span><span class=mi>10</span><span class=o>*</span><span 
class=nx>time</span><span class=p>.</span><span class=nx>Minute</span><span 
class=p>))),</span>
        <span class=nx>beam</span><span class=p>.</span><span 
class=nf>AllowedLateness</span><span class=p>(</span><span 
class=mi>2</span><span class=o>*</span><span class=mi>24</span><span 
class=o>*</span><span class=nx>time</span><span class=p>.</span><span 
class=nx>Hour</span><span class=p>),</span>
 <span class=p>)</span></code></pre></div></div></div><h4 
id=other-composite-triggers>9.5.3. Other composite triggers</h4><p>You can also 
build other sorts of composite triggers. The following example code
@@ -4255,7 +4255,7 @@ expansionAddr := &#34;localhost:8097&#34;
 outT := beam.UnnamedOutput(typex.New(reflectx.String))
 res := beam.CrossLanguage(s, urn, payload, expansionAddr, 
beam.UnnamedInput(inputPCol), outT)
    </code></pre></div></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>Google Cloud Dataflow supports multi-language 
pipelines through the Dataflow Runner v2 backend architecture.</p><div 
class=feedback><p class=update>Last updated on 2021/10/25</p><h3>Have you found 
everything you were looking for?</h3><p class=descr [...]
+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>Google Cloud Dataflow supports multi-language 
pipelines through the Dataflow Runner v2 backend architecture.</p><div 
class=feedback><p class=update>Last updated on 2021/11/10</p><h3>Have you found 
everything you were looking for?</h3><p class=descr [...]
 <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></div></footer></body></html>
\ No newline at end of file
diff --git a/website/generated-content/sitemap.xml 
b/website/generated-content/sitemap.xml
index f485716..74acf4e 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>/categories/blog/</loc><lastmod>2021-11-05T13:17:18-07:00</lastmod></url><url><loc>/blog/</loc><lastmod>2021-11-05T13:17:18-07:00</lastmod></url><url><loc>/categories/</loc><lastmod>2021-11-05T13:17:18-07:00</lastmod></url><url><loc>/blog/go-sdk-release/</loc><lastmod>2021-11-05T13:17:18-07:00</lastmod></url><url><loc>/blo
 [...]
\ 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>/categories/blog/</loc><lastmod>2021-11-05T13:17:18-07:00</lastmod></url><url><loc>/blog/</loc><lastmod>2021-11-05T13:17:18-07:00</lastmod></url><url><loc>/categories/</loc><lastmod>2021-11-05T13:17:18-07:00</lastmod></url><url><loc>/blog/go-sdk-release/</loc><lastmod>2021-11-05T13:17:18-07:00</lastmod></url><url><loc>/blo
 [...]
\ No newline at end of file