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 40f655a Publishing website 2020/10/09 00:06:53 at commit 571338b
40f655a is described below
commit 40f655a7b55a645c0b673549e552df43c9173278
Author: jenkins <bui...@apache.org>
AuthorDate: Fri Oct 9 00:06:54 2020 +0000
Publishing website 2020/10/09 00:06:53 at commit 571338b
---
website/generated-content/documentation/index.xml | 12 ++--
.../documentation/programming-guide/index.html | 12 ++--
.../images/unwindowed-pipeline-bounded.svg | 31 +++++------
.../images/windowing-pipeline-bounded.svg | 37 ++++++-------
.../images/windowing-pipeline-unbounded.svg | 64 +++++++++++-----------
website/generated-content/sitemap.xml | 2 +-
6 files changed, 74 insertions(+), 84 deletions(-)
diff --git a/website/generated-content/documentation/index.xml
b/website/generated-content/documentation/index.xml
index cb772ab..3c75142 100644
--- a/website/generated-content/documentation/index.xml
+++ b/website/generated-content/documentation/index.xml
@@ -5691,8 +5691,8 @@ transform in the Beam SDK for Java).</p>
pipeline processes data, consider the following pipeline:</p>
<p><img src="/images/unwindowed-pipeline-bounded.svg" alt="Diagram of
GroupByKey and ParDo without windowing, on a bounded collection"></p>
<p><strong>Figure 4:</strong> <code>GroupByKey</code> and
<code>ParDo</code> without windowing, on a bounded collection.</p>
-<p>In the above pipeline, we create a bounded
<code>PCollection</code> by reading a set of
-key/value pairs using <code>TextIO</code>. We then group the collection
using <code>GroupByKey</code>,
+<p>In the above pipeline, we create a bounded
<code>PCollection</code> by reading lines from a
+file using <code>TextIO</code>. We then group the collection using
<code>GroupByKey</code>,
and apply a <code>ParDo</code> transform to the grouped
<code>PCollection</code>. In this example, the
<code>GroupByKey</code> creates a collection of unique keys, and then
<code>ParDo</code> gets applied
exactly once per key.</p>
@@ -5701,8 +5701,8 @@ all elements in your <code>PCollection</code> are
assigned to a single glo
<p>Now, consider the same pipeline, but using a windowing function:</p>
<p><img src="/images/windowing-pipeline-bounded.svg" alt="Diagram of
GroupByKey and ParDo with windowing, on a bounded collection"></p>
<p><strong>Figure 5:</strong> <code>GroupByKey</code> and
<code>ParDo</code> with windowing, on a bounded collection.</p>
-<p>As before, the pipeline creates a bounded <code>PCollection</code>
of key/value pairs. We
-then set a <a
href="#setting-your-pcollections-windowing-function">windowing function</a>
+<p>As before, the pipeline creates a bounded <code>PCollection</code>
by reading lines from a
+file. We then set a <a
href="#setting-your-pcollections-windowing-function">windowing function</a>
for that <code>PCollection</code>. The <code>GroupByKey</code>
transform groups the elements of the
<code>PCollection</code> by both key and window, based on the windowing
function. The
subsequent <code>ParDo</code> transform gets applied multiple times per
key, once for each
@@ -6073,9 +6073,9 @@ sets the window&rsquo;s <strong>accumulation
mode</strong>.</p>
<span class="o">.</span><span
class="na">discardingFiredPanes</span><span
class="o">());</span></code></pre></div>
</div>
<div class=language-py>
-<div class="highlight"><pre class="chroma"><code class="language-py"
data-lang="py"><span class="n">pcollection</span> <span
class="o">|</span> <span class="n">WindowInto</span><span
class="p">(</span>
+<div class="highlight"><pre class="chroma"><code class="language-py"
data-lang="py"> <span class="n">pcollection</span> <span
class="o">|</span> <span class="n">WindowInto</span><span
class="p">(</span>
<span class="n">FixedWindows</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">trigger</span><span class="o">=</span><span
class="n">AfterProcessingTime</span><span class="p">(</span><span
class="mi">10</span> <span class="o">*</span> <span
class="mi">60</span><span class="p">),</span>
+<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>
<h4 id="window-accumulation-modes">9.4.1. Window accumulation modes</h4>
diff --git
a/website/generated-content/documentation/programming-guide/index.html
b/website/generated-content/documentation/programming-guide/index.html
index ee7b7d9..c78f516 100644
--- a/website/generated-content/documentation/programming-guide/index.html
+++ b/website/generated-content/documentation/programming-guide/index.html
@@ -1842,13 +1842,13 @@ each element. To assign timestamps to elements, use a
<code>ParDo</code> transfo
<code>DoFn</code> that outputs each element with a new timestamp (for example,
the
<a
href=https://beam.apache.org/releases/javadoc/2.24.0/index.html?org/apache/beam/sdk/transforms/WithTimestamps.html>WithTimestamps</a>
transform in the Beam SDK for Java).</p><p>To illustrate how windowing with a
bounded <code>PCollection</code> can affect how your
-pipeline processes data, consider the following pipeline:</p><p><img
src=/images/unwindowed-pipeline-bounded.svg alt="Diagram of GroupByKey and
ParDo without windowing, on a bounded collection"></p><p><strong>Figure
4:</strong> <code>GroupByKey</code> and <code>ParDo</code> without windowing,
on a bounded collection.</p><p>In the above pipeline, we create a bounded
<code>PCollection</code> by reading a set of
-key/value pairs using <code>TextIO</code>. We then group the collection using
<code>GroupByKey</code>,
+pipeline processes data, consider the following pipeline:</p><p><img
src=/images/unwindowed-pipeline-bounded.svg alt="Diagram of GroupByKey and
ParDo without windowing, on a bounded collection"></p><p><strong>Figure
4:</strong> <code>GroupByKey</code> and <code>ParDo</code> without windowing,
on a bounded collection.</p><p>In the above pipeline, we create a bounded
<code>PCollection</code> by reading lines from a
+file using <code>TextIO</code>. We then group the collection using
<code>GroupByKey</code>,
and apply a <code>ParDo</code> transform to the grouped
<code>PCollection</code>. In this example, the
<code>GroupByKey</code> creates a collection of unique keys, and then
<code>ParDo</code> gets applied
exactly once per key.</p><p>Note that even if you don’t set a windowing
function, there is still a window –
-all elements in your <code>PCollection</code> are assigned to a single global
window.</p><p>Now, consider the same pipeline, but using a windowing
function:</p><p><img src=/images/windowing-pipeline-bounded.svg alt="Diagram of
GroupByKey and ParDo with windowing, on a bounded
collection"></p><p><strong>Figure 5:</strong> <code>GroupByKey</code> and
<code>ParDo</code> with windowing, on a bounded collection.</p><p>As before,
the pipeline creates a bounded <code>PCollection</code> of key/v [...]
-then set a <a href=#setting-your-pcollections-windowing-function>windowing
function</a>
+all elements in your <code>PCollection</code> are assigned to a single global
window.</p><p>Now, consider the same pipeline, but using a windowing
function:</p><p><img src=/images/windowing-pipeline-bounded.svg alt="Diagram of
GroupByKey and ParDo with windowing, on a bounded
collection"></p><p><strong>Figure 5:</strong> <code>GroupByKey</code> and
<code>ParDo</code> with windowing, on a bounded collection.</p><p>As before,
the pipeline creates a bounded <code>PCollection</code> by readi [...]
+file. We then set a <a
href=#setting-your-pcollections-windowing-function>windowing function</a>
for that <code>PCollection</code>. The <code>GroupByKey</code> transform
groups the elements of the
<code>PCollection</code> by both key and window, based on the windowing
function. The
subsequent <code>ParDo</code> transform gets applied multiple times per key,
once for each
@@ -2079,9 +2079,9 @@ sets the window’s <strong>accumulation
mode</strong>.</p><div class=langua
<span class=n>pc</span><span class=o>.</span><span
class=na>apply</span><span class=o>(</span><span class=n>Window</span><span
class=o>.<</span><span class=n>String</span><span class=o>></span><span
class=n>into</span><span class=o>(</span><span class=n>FixedWindows</span><span
class=o>.</span><span class=na>of</span><span class=o>(</span><span
class=n>1</span><span class=o>,</span> <span class=n>TimeUnit</span><span
class=o>.</span><span class=na>MINUTES</span><span class=o>))</span>
<span class=o>.</span><span
class=na>triggering</span><span class=o>(</span><span
class=n>AfterProcessingTime</span><span class=o>.</span><span
class=na>pastFirstElementInPane</span><span class=o>()</span>
<span
class=o>.</span><span class=na>plusDelayOf</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=o>.</span><span
class=na>discardingFiredPanes</span><span
class=o>());</span></code></pre></div></div><div class=language-py><div
class=highlight><pre class=chroma><code class=language-py data-lang=py><span
class=n>pcollection</span> <span class=o>|</span> <span
class=n>WindowInto</span><span class=p>(</span>
+ <span class=o>.</span><span
class=na>discardingFiredPanes</span><span
class=o>());</span></code></pre></div></div><div class=language-py><div
class=highlight><pre class=chroma><code class=language-py data-lang=py> <span
class=n>pcollection</span> <span class=o>|</span> <span
class=n>WindowInto</span><span class=p>(</span>
<span class=n>FixedWindows</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>trigger</span><span class=o>=</span><span
class=n>AfterProcessingTime</span><span class=p>(</span><span
class=mi>10</span> <span class=o>*</span> <span class=mi>60</span><span
class=p>),</span>
+ <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><h4
id=window-accumulation-modes>9.4.1. Window accumulation modes</h4><p>When you
specify a trigger, you must also set the the window’s <strong>accumulation
mode</strong>. When a trigger fires, it emits the current contents of the
window as a
pane. Since a trigger can fire multiple times, the accumulation mode determines
diff --git a/website/generated-content/images/unwindowed-pipeline-bounded.svg
b/website/generated-content/images/unwindowed-pipeline-bounded.svg
index ccf7ab1..c6e3bfa 100644
--- a/website/generated-content/images/unwindowed-pipeline-bounded.svg
+++ b/website/generated-content/images/unwindowed-pipeline-bounded.svg
@@ -37,8 +37,8 @@
<path d="M1072.5,80 L1072.5,100" id="Directed-edge" stroke="#3062A8"
stroke-width="2" stroke-linecap="square" transform="translate(1072.500000,
90.000000) rotate(-90.000000) translate(-1072.500000, -90.000000) "></path>
<g id="PCollection" transform="translate(1084.500000, 55.000000)">
<circle id="PCollection-symbol" stroke="#757575" stroke-width="2"
fill="#FFFFFF" cx="35" cy="35" r="35"></circle>
- <text id="Rows-after-ParDo" font-family="Roboto-Regular, Roboto"
font-size="15" font-weight="normal" fill="#000000">
- <tspan x="17.1015625" y="21">Rows </tspan>
+ <text id="Lines-after-ParDo" font-family="Roboto-Regular, Roboto"
font-size="15" font-weight="normal" fill="#000000">
+ <tspan x="17.1015625" y="21">Lines </tspan>
<tspan x="19.8554688" y="39">after </tspan>
<tspan x="14.9555664" y="57">ParDo</tspan>
</text>
@@ -55,8 +55,8 @@
</g>
<g id="PCollection" transform="translate(763.000000, 61.000000)">
<circle id="PCollection-symbol" stroke="#757575" stroke-width="2"
fill="#FFFFFF" cx="30.9530303" cy="31.2207576" r="30.530303"></circle>
- <text id="Rows-by-key" font-family="Roboto-Regular, Roboto"
font-size="15" font-weight="normal" fill="#000000">
- <tspan x="12.616714" y="27">Rows </tspan>
+ <text id="Lines-by-key" font-family="Roboto-Regular, Roboto"
font-size="15" font-weight="normal" fill="#000000">
+ <tspan x="12.616714" y="27">Lines</tspan>
<tspan x="10.0788722" y="45">by key</tspan>
</text>
</g>
@@ -72,28 +72,23 @@
</g>
<g id="PCollection" transform="translate(374.000000, 61.000000)">
<circle id="PCollection-symbol" stroke="#757575" stroke-width="2"
fill="#FFFFFF" cx="31" cy="31" r="31"></circle>
- <text id="Table-rows" font-family="Roboto-Regular, Roboto"
font-size="16" font-weight="normal" fill="#000000">
- <tspan x="11.2070312" y="28">Table </tspan>
- <tspan x="13.59375" y="47">rows</tspan>
+ <text id="File-lines" font-family="Roboto-Regular, Roboto"
font-size="16" font-weight="normal" fill="#000000">
+ <tspan x="16" y="28">File</tspan>
+ <tspan x="16" y="47">lines</tspan>
</text>
</g>
<g id="PTransform" transform="translate(160.000000, 30.000000)">
<rect id="PTransform-symbol" fill="#3062A8" x="0" y="0"
width="194" height="124"></rect>
- <text id="Read-from-Kafka-IO" font-family="Roboto-Regular, Roboto"
font-size="24" font-weight="normal" fill="#FFFFFF">
+ <text id="Read-from-Text-IO" font-family="Roboto-Regular, Roboto"
font-size="24" font-weight="normal" fill="#FFFFFF">
<tspan x="44" y="55">Read from </tspan>
- <tspan x="44" y="83">Kafka IO</tspan>
+ <tspan x="44" y="83">Text IO</tspan>
</text>
</g>
<path id="Directed-edge" d="M146,92 L113,92 L113,90 L146,90 L146,84
L160,91 L146,98 L146,92 Z" fill="#E0E0E0" fill-rule="nonzero"></path>
- <g id="Database" transform="translate(0.000000, 40.000000)">
- <g id="Database-symbol" transform="translate(0.000000, 0.000000)">
- <ellipse id="Oval" fill="#E0E0E0" cx="56.5" cy="83.2631579"
rx="56.5" ry="17.8421053"></ellipse>
- <rect id="Rectangle" fill="#E0E0E0" x="0" y="17.8421053"
width="113" height="65.4210526"></rect>
- <ellipse id="Oval" fill="#EFEFEF" cx="56.5" cy="17.8421053"
rx="56.5" ry="17.8421053"></ellipse>
- </g>
- <text id="Database-table" font-family="Roboto-Regular, Roboto"
font-size="18" font-weight="normal" fill="#414141">
- <tspan x="18" y="61">Database </tspan>
- <tspan x="18" y="82">table</tspan>
+ <g id="Document" transform="translate(0.000000, 50.000000)">
+ <path d="M0,0 L0,81.1880544 C5.73926173,85.0626848 15.1689615,87
28.2890992,87 C56.5,87 57.2032971,71.8576229 84.878475,71.8576229
C90.6940962,71.8576229 100.067938,74.9677667 113,81.1880544 L113,0 L0,0 Z"
id="Document-symbol" fill="#E0E0E0"></path>
+ <text id="Text-file" font-family="Roboto-Regular, Roboto"
font-size="18" font-weight="normal" fill="#414141">
+ <tspan x="25" y="43">Text file</tspan>
</text>
</g>
</g>
diff --git a/website/generated-content/images/windowing-pipeline-bounded.svg
b/website/generated-content/images/windowing-pipeline-bounded.svg
index 743fe2e..076daeb 100644
--- a/website/generated-content/images/windowing-pipeline-bounded.svg
+++ b/website/generated-content/images/windowing-pipeline-bounded.svg
@@ -23,8 +23,8 @@
<path d="M204.5,296 L204.5,316" id="Directed-edge" stroke="#3062A8"
stroke-width="2" stroke-linecap="square" transform="translate(204.500000,
306.000000) rotate(-90.000000) translate(-204.500000, -306.000000) "></path>
<g id="PCollection" transform="translate(214.000000, 271.000000)">
<circle id="PCollection-symbol" stroke="#757575"
stroke-width="2" fill="#FFFFFF" cx="35" cy="35" r="35"></circle>
- <text id="Rows-after-ParDo" font-family="Roboto-Regular,
Roboto" font-size="15" font-weight="normal" fill="#000000">
- <tspan x="17.1015625" y="21">Rows </tspan>
+ <text id="Lines-after-ParDo" font-family="Roboto-Regular,
Roboto" font-size="15" font-weight="normal" fill="#000000">
+ <tspan x="17.1015625" y="21">Lines </tspan>
<tspan x="19.8554688" y="39">after </tspan>
<tspan x="14.9555664" y="57">ParDo</tspan>
</text>
@@ -60,9 +60,9 @@
</g>
<g id="PCollection" transform="translate(696.500000, 61.000000)">
<circle id="PCollection-symbol" stroke="#757575"
stroke-width="2" fill="#FFFFFF" cx="31" cy="31" r="31"></circle>
- <text id="Table-rows" font-family="Roboto-Regular, Roboto"
font-size="16" font-weight="normal" fill="#000000">
- <tspan x="11.7070312" y="28">Table </tspan>
- <tspan x="14.09375" y="47">rows</tspan>
+ <text id="File-lines" font-family="Roboto-Regular, Roboto"
font-size="16" font-weight="normal" fill="#000000">
+ <tspan x="16" y="28">File</tspan>
+ <tspan x="16" y="47">lines</tspan>
</text>
</g>
<g id="PTransform" transform="translate(482.000000, 30.000000)">
@@ -78,30 +78,25 @@
</g>
<g id="PCollection" transform="translate(374.000000, 61.000000)">
<circle id="PCollection-symbol" stroke="#757575"
stroke-width="2" fill="#FFFFFF" cx="31" cy="31" r="31"></circle>
- <text id="Table-rows" font-family="Roboto-Regular, Roboto"
font-size="16" font-weight="normal" fill="#000000">
- <tspan x="11.2070312" y="28">Table </tspan>
- <tspan x="13.59375" y="47">rows</tspan>
+ <text id="File-lines" font-family="Roboto-Regular, Roboto"
font-size="16" font-weight="normal" fill="#000000">
+ <tspan x="16" y="28">File</tspan>
+ <tspan x="16" y="47">lines</tspan>
</text>
</g>
<g id="PTransform" transform="translate(160.000000, 30.000000)">
<rect id="PTransform-symbol" fill="#3062A8" x="0" y="0"
width="194" height="124"></rect>
- <text id="Read-from-Kafka-IO" font-family="Roboto-Regular,
Roboto" font-size="24" font-weight="normal" fill="#FFFFFF">
+ <text id="Read-from-Text-IO" font-family="Roboto-Regular,
Roboto" font-size="24" font-weight="normal" fill="#FFFFFF">
<tspan x="44" y="55">Read from </tspan>
- <tspan x="44" y="83">Kafka IO</tspan>
+ <tspan x="44" y="83">Text IO</tspan>
</text>
</g>
<path id="Directed-edge" d="M146,92 L113,92 L113,90 L146,90 L146,84
L160,91 L146,98 L146,92 Z" fill="#E0E0E0" fill-rule="nonzero"></path>
- <g id="Database" transform="translate(0.000000, 40.000000)">
- <g id="Database-symbol" transform="translate(0.000000,
0.000000)">
- <ellipse id="Oval" fill="#E0E0E0" cx="56.5" cy="83.2631579"
rx="56.5" ry="17.8421053"></ellipse>
- <rect id="Rectangle" fill="#E0E0E0" x="0" y="17.8421053"
width="113" height="65.4210526"></rect>
- <ellipse id="Oval" fill="#EFEFEF" cx="56.5" cy="17.8421053"
rx="56.5" ry="17.8421053"></ellipse>
- </g>
- <text id="Database-table" font-family="Roboto-Regular, Roboto"
font-size="18" font-weight="normal" fill="#414141">
- <tspan x="18" y="61">Database </tspan>
- <tspan x="18" y="82">table</tspan>
- </text>
- </g>
+ <g id="Document" transform="translate(0.000000, 50.000000)">
+ <path d="M0,0 L0,81.1880544 C5.73926173,85.0626848 15.1689615,87
28.2890992,87 C56.5,87 57.2032971,71.8576229 84.878475,71.8576229
C90.6940962,71.8576229 100.067938,74.9677667 113,81.1880544 L113,0 L0,0 Z"
id="Document-symbol" fill="#E0E0E0"></path>
+ <text id="Text-file" font-family="Roboto-Regular, Roboto"
font-size="18" font-weight="normal" fill="#414141">
+ <tspan x="25" y="43">Text file</tspan>
+ </text>
+ </g>
<g id="Legend" transform="translate(0.000000, 388.000000)">
<rect id="PTransform-symbol" fill="#3062A8" x="0" y="4"
width="15" height="15"></rect>
<text id="PTransform" font-family="Roboto-Regular, Roboto"
font-size="18" font-weight="normal" fill="#000000">
diff --git a/website/generated-content/images/windowing-pipeline-unbounded.svg
b/website/generated-content/images/windowing-pipeline-unbounded.svg
index ef8a0dd..88a81e6 100644
--- a/website/generated-content/images/windowing-pipeline-unbounded.svg
+++ b/website/generated-content/images/windowing-pipeline-unbounded.svg
@@ -19,21 +19,21 @@
-->
<svg width="1158px" height="468px" viewBox="0 0 1158 468" version="1.1"
xmlns="http://www.w3.org/2000/svg"; xmlns:xlink="http://www.w3.org/1999/xlink";>
<title>Pipeline applying windowing.</title>
- <g id="windowing-pipeline-unbounded" transform="translate(1.000000,
0.000000)">
- <g id="Legend" transform="translate(0.000000, 413.000000)">
- <rect id="PTransform-symbol" fill="#3062A8" x="0" y="4"
width="15" height="15"></rect>
- <text id="PTransform" font-family="Roboto-Regular, Roboto"
font-size="18" font-weight="normal" fill="#000000">
- <tspan x="22" y="17">PTransform</tspan>
- </text>
- <text id="Aggregation" font-family="Roboto-Regular, Roboto"
font-size="18" font-weight="normal" fill="#000000">
- <tspan x="162" y="17">Aggregating PTransform</tspan>
- </text>
- <text id="PCollection" font-family="Roboto-Regular, Roboto"
font-size="18" font-weight="normal" fill="#000000">
- <tspan x="22" y="52">PCollection</tspan>
- </text>
- <circle id="PCollection-symbol" fill="#FFFFFF" stroke="#757575"
stroke-width="2" cx="7.5" cy="46.5" r="7.5"></circle>
- <path d="M143.364341,5 L154,12.4782609 L143.364341,20
L133,12.5217391 L143.364341,5 Z" id="Rectangle" fill="#3062A8"></path>
- </g>
+ <g id="windowing-pipeline-unbounded" transform="translate(1.000000,
0.000000)">
+ <g id="Legend" transform="translate(0.000000, 413.000000)">
+ <rect id="PTransform-symbol" fill="#3062A8" x="0" y="4" width="15"
height="15"></rect>
+ <text id="PTransform" font-family="Roboto-Regular, Roboto"
font-size="18" font-weight="normal" fill="#000000">
+ <tspan x="22" y="17">PTransform</tspan>
+ </text>
+ <text id="Aggregation" font-family="Roboto-Regular, Roboto"
font-size="18" font-weight="normal" fill="#000000">
+ <tspan x="162" y="17">Aggregating PTransform</tspan>
+ </text>
+ <text id="PCollection" font-family="Roboto-Regular, Roboto"
font-size="18" font-weight="normal" fill="#000000">
+ <tspan x="22" y="52">PCollection</tspan>
+ </text>
+ <circle id="PCollection-symbol" fill="#FFFFFF" stroke="#757575"
stroke-width="2" cx="7.5" cy="46.5" r="7.5"></circle>
+ <path d="M143.364341,5 L154,12.4782609 L143.364341,20
L133,12.5217391 L143.364341,5 Z" id="Rectangle" fill="#3062A8"></path>
+ </g>
<path d="M270.05,290.765 L270.05,310.765" id="Directed-edge"
stroke="#3062A8" stroke-width="2" stroke-linecap="square"
transform="translate(270.050000, 300.765000) rotate(-90.000000)
translate(-270.050000, -300.765000) "></path>
<g id="PCollection" transform="translate(281.550000, 257.265000)">
<circle id="PCollection-symbol" stroke="#757575" stroke-width="2"
fill="#FFFFFF" cx="42.5" cy="42.5" r="42.5"></circle>
@@ -57,9 +57,9 @@
<g id="PCollection" transform="translate(1021.000000, 27.000000)">
<circle id="PCollection-symbol" stroke="#757575" stroke-width="2"
fill="#FFFFFF" cx="35" cy="35" r="35"></circle>
<text id="Rows-after-ParDo" font-family="Roboto-Regular, Roboto"
font-size="15" font-weight="normal" fill="#000000">
- <tspan x="17.1015625" y="21">Rows </tspan>
- <tspan x="19.8554688" y="39">after </tspan>
- <tspan x="14.9555664" y="57">ParDo</tspan>
+ <tspan x="20" y="21">Coll </tspan>
+ <tspan x="20" y="39">after </tspan>
+ <tspan x="17" y="57">ParDo</tspan>
</text>
</g>
<g id="PTransform" transform="translate(804.500000, 0.000000)">
@@ -74,9 +74,9 @@
</g>
<g id="PCollection" transform="translate(696.500000, 31.000000)">
<circle id="PCollection-symbol" stroke="#757575" stroke-width="2"
fill="#FFFFFF" cx="31" cy="31" r="31"></circle>
- <text id="Table-rows" font-family="Roboto-Regular, Roboto"
font-size="16" font-weight="normal" fill="#000000">
- <tspan x="11.7070312" y="28">Table </tspan>
- <tspan x="14.09375" y="47">rows</tspan>
+ <text id="KV-pairs" font-family="Roboto-Regular, Roboto"
font-size="16" font-weight="normal" fill="#000000">
+ <tspan x="17" y="28">K/V</tspan>
+ <tspan x="16" y="47">pairs</tspan>
</text>
</g>
<g id="PTransform" transform="translate(482.000000, 0.000000)">
@@ -92,9 +92,9 @@
</g>
<g id="PCollection" transform="translate(374.000000, 31.000000)">
<circle id="PCollection-symbol" stroke="#757575" stroke-width="2"
fill="#FFFFFF" cx="31" cy="31" r="31"></circle>
- <text id="Table-rows" font-family="Roboto-Regular, Roboto"
font-size="16" font-weight="normal" fill="#000000">
- <tspan x="11.2070312" y="28">Table </tspan>
- <tspan x="13.59375" y="47">rows</tspan>
+ <text id="KV-pairs" font-family="Roboto-Regular, Roboto"
font-size="16" font-weight="normal" fill="#000000">
+ <tspan x="17" y="28">K/V</tspan>
+ <tspan x="16" y="47">pairs</tspan>
</text>
</g>
<g id="PTransform" transform="translate(160.000000, 0.000000)">
@@ -105,16 +105,16 @@
</text>
</g>
<path id="Directed-edge" d="M146,62 L113,62 L113,60 L146,60 L146,54
L160,61 L146,68 L146,62 Z" fill="#E0E0E0" fill-rule="nonzero"></path>
- <g id="Database" transform="translate(0.000000, 10.000000)">
- <g id="Database-symbol" transform="translate(0.000000, 0.000000)">
+ <g id="Kafka" transform="translate(0.000000, 10.000000)">
+ <g id="Kafka-topic-symbol" transform="translate(0.000000,
0.000000)">
<ellipse id="Oval" fill="#E0E0E0" cx="56.5" cy="83.2631579"
rx="56.5" ry="17.8421053"></ellipse>
<rect id="Rectangle" fill="#E0E0E0" x="0" y="17.8421053"
width="113" height="65.4210526"></rect>
<ellipse id="Oval" fill="#EFEFEF" cx="56.5" cy="17.8421053"
rx="56.5" ry="17.8421053"></ellipse>
</g>
- <text id="Database-table" font-family="Roboto-Regular, Roboto"
font-size="18" font-weight="normal" fill="#414141">
- <tspan x="18" y="61">Database </tspan>
- <tspan x="18" y="82">table</tspan>
+ <text id="Kafka-topic" font-family="Roboto-Regular, Roboto"
font-size="18" font-weight="normal" fill="#414141">
+ <tspan x="34" y="61">Kafka </tspan>
+ <tspan x="34" y="82">topic</tspan>
</text>
- </g>
- </g>
-</svg>
\ No newline at end of file
+ </g>
+ </g>
+</svg>
diff --git a/website/generated-content/sitemap.xml
b/website/generated-content/sitemap.xml
index 37bba15..dd62a32 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>/blog/beam-2.24.0/</loc><lastmod>2020-09-18T12:38:38-07:00</lastmod></url><url><loc>/categories/blog/</loc><lastmod>2020-09-18T12:38:38-07:00</lastmod></url><url><loc>/blog/</loc><lastmod>2020-09-18T12:38:38-07:00</lastmod></url><url><loc>/categories/</loc><lastmod>2020-09-18T12:38:38-07:00</lastmod></url><url><loc>/blog/p
[...]
\ 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>/blog/beam-2.24.0/</loc><lastmod>2020-09-18T12:38:38-07:00</lastmod></url><url><loc>/categories/blog/</loc><lastmod>2020-09-18T12:38:38-07:00</lastmod></url><url><loc>/blog/</loc><lastmod>2020-09-18T12:38:38-07:00</lastmod></url><url><loc>/categories/</loc><lastmod>2020-09-18T12:38:38-07:00</lastmod></url><url><loc>/blog/p
[...]
\ No newline at end of file
