You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 1048262223 <10...@qq.com> on 2020/06/10 01:47:21 UTC
回复: 回复:flink如何传递全局变量
Hi
Broadcast可以参考这个[1],open其实就是直接在open时加载
[1]https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/state/broadcast_state.html
Best,
Yichao Yang
------------------ 原始邮件 ------------------
发件人: "zjfplayer@hotmail.com"<zjfplayer@hotmail.com>;
发送时间: 2020年6月10日(星期三) 上午9:16
收件人: "1048262223"<1048262223@qq.com>;
抄送: "user-zh"<user-zh@flink.apache.org>;
主题: 回复: 回复:flink如何传递全局变量
有相关的代码例子可以参考下吗?
zjfplayer@hotmail.com
发件人: 1048262223
发送时间: 2020-06-09 20:17
收件人: user-zh
主题: 回复:flink如何传递全局变量
Hi
使用rich function,在open方法中加载,如果配置可能会发生变化,可以使用broadcast。
Best,
Yichao Yang
------------------&nbsp;原始邮件&nbsp;------------------
发件人:&nbsp;"zjfplayer@hotmail.com"<zjfplayer@hotmail.com&gt;;
发送时间:&nbsp;2020年6月9日(星期二) 晚上8:14
收件人:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;
主题:&nbsp;flink如何传递全局变量
hi,
&nbsp;&nbsp;&nbsp; 请问flink如何传递全局变量,静态类好像服务器端运行不行。
&nbsp;&nbsp;&nbsp; 场景是:一开始flink程序起来时,读取配置文件中的配置项,此类配置项可能会在sink,source等等其他地方用到,算是整个程序的全局配置
zjfplayer@hotmail.com