Позволяет ли Flink Broadcast State реализовывать правило, основанное на временном окне?

Question

У меня есть вариант использования: предположим, я хочу создать правило, согласно которому все события, которые были сгенерированы с определенного IP-адреса в течение 5-минутного интервала времени, должны переходить к определенной теме;У меня может быть несколько таких правил в моем состоянии вещания.

Answer 1

Реализация этого с одним из встроенных окон Flink может быть немного сложнее, потому что вам нужно будет распределить логику по различным функциям, например, функции широковещания и функции окна.

Однако выможет реализовать логику управления окнами также только в KeyedBroadcastProcessFunction.Он обеспечивает TimerService (для регистрации таймеров и поиска текущего времени) и состояние ключа, так что может быть реализована вся необходимая логика.Широковещательный вход затем используется для настройки поведения.

На самом деле вам может даже не понадобиться функция широковещания, если правила всегда применяются к ключу, то есть IP-адресу.