Мы столкнулись с проблемой с mapGroupswithState обработкой с учетом состояния.
Требование: введите все данные и ключ groupBy и примените тайм-аут для этого состояния.Затем, после истечения времени ожидания, мы хотим запустить его в нисходящих системах.Помогите мне понять, вызывается ли state.hasTimedOut, даже если мы не вызываем метод функции с использованием этого ключа после истечения времени ожидания?Например, Alarm1 имеет состояние и время ожидания истекло, получаем ли мы какое-либо указание или триггер для этого конкретного состояния?
Мы делаем небольшое преобразование данных потока, и все, что мы хотим сделать, - это отправить предупреждение в нисходящие системы погрупповое состояние индивидуально.Есть ли способ отправить данные по тайм-ауту в нисходящий поток?Если искровая структурированная потоковая передача не подходит для этого сценария, есть ли другая технология, которая может решить этот вариант использования.