Python UDF from Java

classic Classic list List threaded Threaded
4 messages Options
Reply | Threaded
Open this post in threaded view
|

Python UDF from Java

Flavio Pompermaier
Hi to all,
is it possible to run a Python UDF from a Java job (using Table API or SQL)?
Is there any reference?

Best,
Flavio
Reply | Threaded
Open this post in threaded view
|

Re: Python UDF from Java

Marta Paes Moreira
Hi, Flavio.

Extending the scope of Python UDFs is described in FLIP-106 [1, 2] and is planned for the upcoming 1.11 release, according to Piotr's last update.

Hope this addresses your question!

Marta

[1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-106%3A+Support+Python+UDF+in+SQL+Function+DDL
[2] http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-FLIP-106-Support-Python-UDF-in-SQL-Function-DDL-td38107.html

On Thu, Apr 30, 2020 at 11:30 PM Flavio Pompermaier <[hidden email]> wrote:
Hi to all,
is it possible to run a Python UDF from a Java job (using Table API or SQL)?
Is there any reference?

Best,
Flavio
Reply | Threaded
Open this post in threaded view
|

Re: Python UDF from Java

Flavio Pompermaier
Yes, that's awesome! I think this would be a really attractive feature to promote the usage of Flink.

Thanks Marta,
Flavio

On Fri, May 1, 2020 at 12:26 AM Marta Paes Moreira <[hidden email]> wrote:
Hi, Flavio.

Extending the scope of Python UDFs is described in FLIP-106 [1, 2] and is planned for the upcoming 1.11 release, according to Piotr's last update.

Hope this addresses your question!

Marta

[1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-106%3A+Support+Python+UDF+in+SQL+Function+DDL
[2] http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-FLIP-106-Support-Python-UDF-in-SQL-Function-DDL-td38107.html

On Thu, Apr 30, 2020 at 11:30 PM Flavio Pompermaier <[hidden email]> wrote:
Hi to all,
is it possible to run a Python UDF from a Java job (using Table API or SQL)?
Is there any reference?

Best,
Flavio

Reply | Threaded
Open this post in threaded view
|

Re: Python UDF from Java

jincheng sun
Thanks Flavio  and Thanks Marta,

That's a good question  as many user want to know that!
 
CC to user-zh mailing list :)

Best,
Jincheng
-------------
-------------


Flavio Pompermaier <[hidden email]> 于2020年5月1日周五 上午7:04写道:
Yes, that's awesome! I think this would be a really attractive feature to promote the usage of Flink.

Thanks Marta,
Flavio

On Fri, May 1, 2020 at 12:26 AM Marta Paes Moreira <[hidden email]> wrote:
Hi, Flavio.

Extending the scope of Python UDFs is described in FLIP-106 [1, 2] and is planned for the upcoming 1.11 release, according to Piotr's last update.

Hope this addresses your question!

Marta

[1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-106%3A+Support+Python+UDF+in+SQL+Function+DDL
[2] http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-FLIP-106-Support-Python-UDF-in-SQL-Function-DDL-td38107.html

On Thu, Apr 30, 2020 at 11:30 PM Flavio Pompermaier <[hidden email]> wrote:
Hi to all,
is it possible to run a Python UDF from a Java job (using Table API or SQL)?
Is there any reference?

Best,
Flavio