Основанные на времени триггеры в глобальном окне в Apache Beam

Question

Я ищу четкую документацию и / или пример того, как настроить основанный на времени триггер для глобального окна в луче Apache.

Цель состоит в том, чтобы выполнить подсчет событий с моментасрабатывает последний триггер, даже если с тех пор было добавлено 0 событий.

Answer 1

Вы можете использовать таймеры и состояния, если вам нужно использовать глобальное окно и генерировать результат, даже если с момента последнего запуска не было никакого события.Я думаю, что это невозможно сделать с помощью встроенных триггеров.

Вы можете держать счет в состоянии и использовать таймер для периодической выдачи результатов.Эти два сообщения в блоге объясняют использование таймеров и состояния:

Обработка с учетом состояния с использованием Apache Beam

Своевременная (и с учетом состояния) обработка с использованием Apache Beam