У меня есть сценарий использования "Apache Flink", где у меня есть конвейер оператора Window, за которым следует Aggregate Operator.Мне нужно настроить объекты метрик (пользовательские метки Non-Flink) для функции агрегирования.Как правило, для других функций я бы использовал метод open () RichFunction для настройки объектов метрик с помощью внедрения Guice.Однако Flink не поддерживает RichFunction для AllWindowStream @ здесь .Любые предложения или другие способы достижения этого?
Спасибо.