Я использую потоковую передачу Flink для замены потока ETL.Одна из задач, над которой я работаю, - это подсчет отдельных ежедневных активных пользователей.Задача для себя не слишком сложна для выполнения.Дело в том, что мне нужно каждый час обновлять информационную панель о текущем счетчике.
Если я создаю окно продолжительностью в один час, я получу отчетливый счетчик только за час, но если пользователь вернется в другой час, ябудет считать его дважды.
У кого-нибудь есть идеи?
Спасибо!