Я пытаюсь собирать данные ежемесячно (используя TumblingEventTime Windows), но хочу обновлять вывод каждый день.
1) Является ли пользовательский триггер лучшим решением этой проблемы?
2) Как подготовить такой триггер в scala?