Я хочу узнать, есть ли таймер в Flink и как бы я его реализовал в этом сценарии. В настоящее время я получаю данные, которые содержат геолокацию, скорость и т. д. от транспортных средств. Для каждого из элементов данных я обрабатываю и создаю события, такие как события превышения скорости, геолокация входа и выхода и т. д. Для одного из видов обработки, который я хочу сделать, это запустить таймер, как только я создам событие входа в геозону, а затем мгновенно запустить функцию для создания другого события по истечении заданного времени. Это необходимо, поскольку может случиться так, что транспортное средство войдет в геозону, но я не получу другой элемент данных за это время, и тогда я хочу создать событие EXCESS_STOP. Возможно ли во Flink иметь таймер и запускать событие по окончании таймера, не получив другой элемент данных в моем источнике Kafka. И если да, что это такое и есть ли где-нибудь информация о том, как это реализовать.
