You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2021/05/03 14:09:10 UTC
[flink-web] branch asf-site updated: Rebuild page
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 8a575a0 Rebuild page
8a575a0 is described below
commit 8a575a0b0b6fd7b0cc1f161f457bd7ad083957d0
Author: Dawid Wysakowicz <dw...@apache.org>
AuthorDate: Mon May 3 16:08:57 2021 +0200
Rebuild page
---
content/blog/feed.xml | 21 ++++++++++-----------
content/news/2021/05/03/release-1.13.0.html | 21 ++++++++++-----------
2 files changed, 20 insertions(+), 22 deletions(-)
diff --git a/content/blog/feed.xml b/content/blog/feed.xml
index 9312bd2..d3a6b6c 100644
--- a/content/blog/feed.xml
+++ b/content/blog/feed.xml
@@ -452,17 +452,16 @@ stream into “buckets” of bounded size), this greatly increases the expressiv
<p>The Python Table API now supports row-based operations, i.e., custom transformation functions on rows.
These functions are an easy way to apply data transformations on tables beyond the built-in functions.</p>
-<p>This is an example of using a <code>map()</code> operation in Python Table API:
-```python
-@udf(result_type=DataTypes.ROW(
- [DataTypes.FIELD(“c1”, DataTypes.BIGINT()),
- DataTypes.FIELD(“c2”, DataTypes.STRING())]))
-def increment_column(r: Row) -&gt; Row:
- return Row(r[0] + 1, r[1])</p>
-
-<p>table = … # type: Table
-mapped_result = table.map(increment_column)
-```</p>
+<p>This is an example of using a <code>map()</code> operation in Python Table API:</p>
+
+<div class="highlight"><pre><code class="language-python"><span class="nd">@udf</span><span class="p">(</span><span class="n">result_type</span><span class="o">=</span><span class="n">DataTypes</span><span class="o">.</span><span class="n">ROW</span><span class="p">(</span>
+ <span class="p">[</span><span class="n">DataTypes</span><span class="o">.</span><span class="n">FIELD</span><span class="p">(</span><span class="s">&quot;c1&quot;</span><span class="p">,</span> <span class="n">DataTypes</span><span class="o">.</span><span class="n">BI [...]
+ <span class="n">DataTypes</span><span class="o">.</span><span class="n">FIELD</span><span class="p">(</span><span class="s">&quot;c2&quot;</span><span class="p">,</span> <span class="n">DataTypes</span><span class="o">.</span><span class="n">STRING</span><span class="p" [...]
+<span class="k">def</span> <span class="nf">increment_column</span><span class="p">(</span><span class="n">r</span><span class="p">:</span> <span class="n">Row</span><span class="p">)</span> <span class="o">-&gt;</span> <span class="n">Row</span><span class="p">:</span>
+ <span class="k">return</span> <span class="n">Row</span><span class="p">(</span><span class="n">r</span><span class="p">[</span><span class="mi">0</span><span class="p">]</span> <span class="o">+</span> <span class="mi">1</span><span class="p">,</span> <span class=&q [...]
+
+<span class="n">table</span> <span class="o">=</span> <span class="o">...</span> <span class="c"># type: Table</span>
+<span class="n">mapped_result</span> <span class="o">=</span> <span class="n">table</span><span class="o">.</span><span class="n">map</span><span class="p">(</span><span class="n">increment_column</span><span class="p">)</span></code></pre></div>
<p>In addition to <code>map()</code>, the API also supports <code>flat_map()</code>, <code>aggregate()</code>, <code>flat_aggregate()</code>,
and other row-based operations. This brings the Python Table API a big step closer to feature
diff --git a/content/news/2021/05/03/release-1.13.0.html b/content/news/2021/05/03/release-1.13.0.html
index 970c2e3..c8ddaa1 100644
--- a/content/news/2021/05/03/release-1.13.0.html
+++ b/content/news/2021/05/03/release-1.13.0.html
@@ -646,17 +646,16 @@ stream into “buckets” of bounded size), this greatly increases the expressiv
<p>The Python Table API now supports row-based operations, i.e., custom transformation functions on rows.
These functions are an easy way to apply data transformations on tables beyond the built-in functions.</p>
-<p>This is an example of using a <code>map()</code> operation in Python Table API:
-```python
-@udf(result_type=DataTypes.ROW(
- [DataTypes.FIELD(“c1”, DataTypes.BIGINT()),
- DataTypes.FIELD(“c2”, DataTypes.STRING())]))
-def increment_column(r: Row) -> Row:
- return Row(r[0] + 1, r[1])</p>
-
-<p>table = … # type: Table
-mapped_result = table.map(increment_column)
-```</p>
+<p>This is an example of using a <code>map()</code> operation in Python Table API:</p>
+
+<div class="highlight"><pre><code class="language-python"><span class="nd">@udf</span><span class="p">(</span><span class="n">result_type</span><span class="o">=</span><span class="n">DataTypes</span><span class="o">.</span><span class="n">ROW</span><span class="p">(</span>
+ <span class="p">[</span><span class="n">DataTypes</span><span class="o">.</span><span class="n">FIELD</span><span class="p">(</span><span class="s">"c1"</span><span class="p">,</span> <span class="n">DataTypes</span><span class="o">.</span><span class="n">BIGINT</span><span class="p">()),</span>
+ <span class="n">DataTypes</span><span class="o">.</span><span class="n">FIELD</span><span class="p">(</span><span class="s">"c2"</span><span class="p">,</span> <span class="n">DataTypes</span><span class="o">.</span><span class="n">STRING</span><span class="p">())]))</span>
+<span class="k">def</span> <span class="nf">increment_column</span><span class="p">(</span><span class="n">r</span><span class="p">:</span> <span class="n">Row</span><span class="p">)</span> <span class="o">-></span> <span class="n">Row</span><span class="p">:</span>
+ <span class="k">return</span> <span class="n">Row</span><span class="p">(</span><span class="n">r</span><span class="p">[</span><span class="mi">0</span><span class="p">]</span> <span class="o">+</span> <span class="mi">1</span><span class="p">,</span> <span class="n">r</span><span class="p">[</span><span class="mi">1</span><span class="p">])</span>
+
+<span class="n">table</span> <span class="o">=</span> <span class="o">...</span> <span class="c"># type: Table</span>
+<span class="n">mapped_result</span> <span class="o">=</span> <span class="n">table</span><span class="o">.</span><span class="n">map</span><span class="p">(</span><span class="n">increment_column</span><span class="p">)</span></code></pre></div>
<p>In addition to <code>map()</code>, the API also supports <code>flat_map()</code>, <code>aggregate()</code>, <code>flat_aggregate()</code>,
and other row-based operations. This brings the Python Table API a big step closer to feature