回复: 回复:flink如何传递全局变量
Posted by
zjfplayer@hotmail.com on
Jun 10, 2020; 1:16am
URL: http://apache-flink.370.s1.nabble.com/flink-tp3763p3774.html
有相关的代码例子可以参考下吗?
[hidden email]
发件人: 1048262223
发送时间: 2020-06-09 20:17
收件人: user-zh
主题: 回复:flink如何传递全局变量
Hi
使用rich function,在open方法中加载,如果配置可能会发生变化,可以使用broadcast。
Best,
Yichao Yang
------------------ 原始邮件 ------------------
发件人: "
[hidden email]"<
[hidden email]>;
发送时间: 2020年6月9日(星期二) 晚上8:14
收件人: "user-zh"<
[hidden email]>;
主题: flink如何传递全局变量
hi,
请问flink如何传递全局变量,静态类好像服务器端运行不行。
场景是:一开始flink程序起来时,读取配置文件中的配置项,此类配置项可能会在sink,source等等其他地方用到,算是整个程序的全局配置
[hidden email]