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 2021/11/11 00:04:00 UTC
[beam] branch asf-site updated: Publishing website 2021/11/11
00:03:25 at commit 1a572cf
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 <bu...@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&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>
@@ -9229,10 +9229,10 @@ firings:</p>
<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">trigger</span> <span class="o">:=</span> <span class="nx">window</span><span class="p">.</span><span class="nf">TriggerAfterEndOfWindow</span><span class="p">().</span>
-<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>
+<div class="highlight"><pre class="chroma"><code class="language-go" data-lang="go"><span class="nx">trigger</span> <span class="o">:=</span> <span class="nx">trigger</span><span class="p">.</span><span class="nf">AfterEndOfWindow</span><span class="p">().</span>
+<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>
+<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>
@@ -9248,7 +9248,7 @@ modifying this behavior.</p>
<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>
@@ -9259,14 +9259,14 @@ window.</p>
<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
@@ -9321,7 +9321,7 @@ The <code>beam.AccumulationMode</code> parameter sets the window&rsquo
</a>
<div class="highlight"><pre class="chroma"><code class="language-go" data-lang="go"><span class="nx">windowedItems</span> <span class="o">:=</span> <span class="nx">beam</span><span class="p">.</span><span class="nf">WindowInto</span><span class="p">(</span><span class="nx">s</span><span class="p">,</span>
<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>
@@ -9414,7 +9414,7 @@ when you set your windowing function:</p>
</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 class="nf">WindowInto</span><span class="p">(</span><span class="nx">s</span><span class="p">,</span>
<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>
@@ -9517,8 +9517,8 @@ trigger stops executing</li>
</a>
<div class="highlight"><pre class="chroma"><code class="language-go" data-lang="go"><span class="nx">compositeTriggerItems</span> <span class="o">:=</span> <span class="nx">beam</span><span class="p">.</span><span class="nf">WindowInto</span><span class="p">(</span><span class="nx">s</span><span class="p">,</span>
<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>
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’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’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’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 “fire
@@ -2822,7 +2822,7 @@ The <code>beam.AccumulationMode</code> parameter sets the window’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 := "localhost:8097"
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