Apache Flink RichAsyncFunction open () вызывается один раз при инициализации или при вызове функции?

Question

Функция open () выполняется один раз при инициализации или каждый раз, когда выполняется функция rich?

Итак, если мы хотим выполнить тяжелую операцию, такую ​​как создание источника данных базы данных, мы можем сделать это там, и он не будет инициироваться при каждом вызове?

Answer 1

Метод open() вызывается один раз во время инициализации оператора для каждого параллельного экземпляра оператора.Так что да, именно здесь вы будете выполнять «тяжелые» одноразовые вызовы инициализации.