回复: 回复：flink如何传递全局变量

["zjfplayer@hotmail.com" <zj...@hotmail.com>]

有相关的代码例子可以参考下吗？



zjfplayer@hotmail.com
 
发件人： 1048262223
发送时间： 2020-06-09 20:17
收件人： user-zh
主题： 回复：flink如何传递全局变量
Hi
 
 
使用rich function，在open方法中加载，如果配置可能会发生变化，可以使用broadcast。
 
 
Best,
Yichao Yang
 
 
 
 
------------------ 原始邮件 ------------------
发件人:&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

回复： 回复：flink如何传递全局变量

[1048262223 <10...@qq.com>]

Hi


Broadcast可以参考这个[1]，open其实就是直接在open时加载




[1]https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/state/broadcast_state.html


Best,
Yichao Yang


------------------ 原始邮件 ------------------
发件人:&nbsp;"zjfplayer@hotmail.com"<zjfplayer@hotmail.com&gt;;
发送时间:&nbsp;2020年6月10日(星期三) 上午9:16
收件人:&nbsp;"1048262223"<1048262223@qq.com&gt;;
抄送:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;
主题:&nbsp;回复: 回复：flink如何传递全局变量



有相关的代码例子可以参考下吗？



zjfplayer@hotmail.com
&nbsp;
发件人： 1048262223
发送时间： 2020-06-09 20:17
收件人： user-zh
主题： 回复：flink如何传递全局变量
Hi
&nbsp;
&nbsp;
使用rich function，在open方法中加载，如果配置可能会发生变化，可以使用broadcast。
&nbsp;
&nbsp;
Best,
Yichao Yang
&nbsp;
&nbsp;
&nbsp;
&nbsp;
------------------&amp;nbsp;原始邮件&amp;nbsp;------------------
发件人:&amp;nbsp;"zjfplayer@hotmail.com"<zjfplayer@hotmail.com&amp;gt;;
发送时间:&amp;nbsp;2020年6月9日(星期二) 晚上8:14
收件人:&amp;nbsp;"user-zh"<user-zh@flink.apache.org&amp;gt;;
&nbsp;
主题:&amp;nbsp;flink如何传递全局变量
&nbsp;
&nbsp;
&nbsp;
hi，
&amp;nbsp;&amp;nbsp;&amp;nbsp; 请问flink如何传递全局变量，静态类好像服务器端运行不行。
&amp;nbsp;&amp;nbsp;&amp;nbsp; 场景是：一开始flink程序起来时，读取配置文件中的配置项，此类配置项可能会在sink，source等等其他地方用到，算是整个程序的全局配置
&nbsp;
&nbsp;
&nbsp;
zjfplayer@hotmail.com