Apache Flink RichAsyncFunction open（）是在init或每次函数调用时调用一次吗？

Question

open（）函数在init或每次执行rich函数时都会执行一次吗？

那么，如果我们想要执行像创建数据库数据源这样繁重的操作，我们可以在那里执行它并且它不会在每次调用时都被引入？

Answer 1

对于运算符的每个并行实例，在运算符初始化期间调用open()方法一次。所以，是的，这是您进行“重”一次性初始化调用的地方。