Как периодически запускать окно?

Question

Я хотел бы обработать последние данные за N-час на каждом M-минутах. Данные поступают через pubsub с различными задержками, но я не хочу задерживать запуск окна из-за перекоса во времени или задержки данных. То есть, я просто хочу обрабатывать данные, доступные во время запуска, и вызывать триггер на основе времени на стене (но каждое окно должно включать данные между [Время запуска - M часов, Время запуска) на основе времени события данных.)

Я пытаюсь использовать SlidingWindows, но запуск основан на времени события и, кажется, задерживается из-за задержки данных.

Каков наилучший способ для этого?

Спасибо,

Answer 1

Вы должны использовать AfterProcessingTime.pastFirstElementInPane().plusDelayOf(...) триггер с FixedWindows. Это будет вести себя точно так же, как вы описываете.