You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by he...@apache.org on 2020/04/10 02:57:09 UTC
[flink-web] 01/02: Update PyFlink Blog date
This is an automated email from the ASF dual-hosted git repository.
hequn pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git
commit 57ed343eac76b050cf99748a465b36569315ff82
Author: hequn8128 <ch...@gmail.com>
AuthorDate: Fri Apr 10 10:51:46 2020 +0800
Update PyFlink Blog date
---
...ort-flink.md => 2020-04-09-pyflink-udf-support-flink.md} | 9 ++++-----
.../pyflink-udf-architecture.png | Bin
.../roadmap-of-pyflink.png | Bin
3 files changed, 4 insertions(+), 5 deletions(-)
diff --git a/_posts/2020-02-23-pyflink-udf-support-flink.md b/_posts/2020-04-09-pyflink-udf-support-flink.md
similarity index 98%
rename from _posts/2020-02-23-pyflink-udf-support-flink.md
rename to _posts/2020-04-09-pyflink-udf-support-flink.md
index b0e46ac..1c655e1 100644
--- a/_posts/2020-02-23-pyflink-udf-support-flink.md
+++ b/_posts/2020-04-09-pyflink-udf-support-flink.md
@@ -1,7 +1,7 @@
---
layout: post
title: "PyFlink: Introducing Python Support for UDFs in Flink's Table API"
-date: 2020-02-23T12:00:00.000Z
+date: 2020-04-09T12:00:00.000Z
authors:
- Jincheng:
name: "Jincheng Sun"
@@ -24,7 +24,7 @@ Before diving into how you can define and use Python UDFs, we explain the motiva
The PyFlink architecture mainly includes two parts — local and cluster — as shown in the architecture visual below. The local phase is the compilation of the job, and the cluster is the execution of the job.
<center>
-<img src="{{ site.baseurl }}/img/blog/2020-02-23-pyflink-udfs/pyflink-udf-architecture.png" width="600px" alt="PyFlink UDF Architecture"/>
+<img src="{{ site.baseurl }}/img/blog/2020-04-09-pyflink-udfs/pyflink-udf-architecture.png" width="600px" alt="PyFlink UDF Architecture"/>
</center>
<br>
@@ -171,14 +171,13 @@ def add(i, j):
To make it available on the worker node that does not contain the dependency, you can specify the dependencies with the following commands and API:
-```shell
+```bash
$ cd /tmp
$ echo mpmath==1.1.0 > requirements.txt
$ pip download -d cached_dir -r requirements.txt --no-binary :all:
```
```python
-
t_env.set_python_requirements("/tmp/requirements.txt", "/tmp/cached_dir")
```
@@ -190,6 +189,6 @@ A `requirements.txt` file that defines the third-party dependencies is used. If
In this blog post, we introduced the architecture of Python UDFs in PyFlink and provided some examples on how to define, register and invoke UDFs. Flink 1.10 brings Python support in the framework to new levels, allowing Python users to write even more magic with their preferred language. The community is actively working towards continuously improving the functionality and performance of PyFlink. Future work in upcoming releases will introduce support for Pandas UDFs in scalar and aggre [...]
<center>
-<img src="{{ site.baseurl }}/img/blog/2020-02-23-pyflink-udfs/roadmap-of-pyflink.png" width="600px" alt="Roadmap of PyFlink"/>
+<img src="{{ site.baseurl }}/img/blog/2020-04-09-pyflink-udfs/roadmap-of-pyflink.png" width="600px" alt="Roadmap of PyFlink"/>
</center>
<br>
diff --git a/img/blog/2020-02-23-pyflink-udfs/pyflink-udf-architecture.png b/img/blog/2020-04-09-pyflink-udfs/pyflink-udf-architecture.png
similarity index 100%
rename from img/blog/2020-02-23-pyflink-udfs/pyflink-udf-architecture.png
rename to img/blog/2020-04-09-pyflink-udfs/pyflink-udf-architecture.png
diff --git a/img/blog/2020-02-23-pyflink-udfs/roadmap-of-pyflink.png b/img/blog/2020-04-09-pyflink-udfs/roadmap-of-pyflink.png
similarity index 100%
rename from img/blog/2020-02-23-pyflink-udfs/roadmap-of-pyflink.png
rename to img/blog/2020-04-09-pyflink-udfs/roadmap-of-pyflink.png