У меня есть поток событий, созданных клиентскими логинами. Каждый клиент может настроить оповещение для запуска, когда порог входов в систему ( x ) нарушен в окне ( y ) минут.
Каждый клиент может установитьзначения x и y .
Я могу обрабатывать различные значения x , поскольку полезная нагрузка события может содержать порог для x , но я не вижу, как обрабатывать различные значения y , поскольку длина окна в Beam является статической.
Я мог бы создать окно для каждого клиента изадайте длину, но каждый раз, когда клиент меняет длину своего окна, мне придется заново развертывать.
Итак, 1, может ли Beam запустить одно окно с разными длительностями для каждого ключа? И 2, может ли Beam обрабатывать окна различной длины без необходимости создавать несколько окон? И 3, как я могу обновить окна длиной без необходимости повторного развертывания ?