.print(c);
> }
> }
>
>
> -- 原始邮件 --------------
> 发件人: "user-zh" mailto:weizhong0...@gmail.com>>;
> 发送时间: 2021年2月5日(星期五) 晚上6:01
> 收件人: "user-zh"mailto:user-zh@flink.apache.org>>;
> 主题: Re: pyflink的py4j里是不是可以调用我自
--- 原始邮件 --
> 发件人: "user-zh" ;
> 发送时间: 2021年2月5日(星期五) 下午3:53
> 收件人: "user-zh";
> 主题: Re: pyflink的py4j里是不是可以调用我自己写的java程序 ？
>
> Hi,
>
> 首先你需要将你的java程序打成jar包，之后热加载你的jar包, 目前pyflink里有一个util方法可以直接调用:
> from pyflink.util.utils import add_ja
原始邮件--
> 发件人:
> "user-zh"
>
> 发送时间:2021年2月5日(星期五) 上午10:35
> 收件人:"user-zh"
> 主题:Re
Hi,
你是想使用java写的udfs吗，你可以调用register_java_function或者create_java_temporary_function来注册你用java写的udfs，具体可以参考文档[1]
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/python/table-api-users-guide/udfs/python_udfs.html#scalar-functions
Best,
Xingbo
瞿叶奇 <389243...@qq.com> 于2021年2月4日周四
