Потоковая передача биржевых котировок из Pub/Sub в Dataflow требует вычисления скользящего среднего за последние 30 секунд каждые 5 секунд. Как следует настроить окна и триггеры?

Правильный ответ — использование скользящего окна длительностью 30 секунд и периодом 5 секунд с триггером AfterWatermark.pastEndOfWindow(). Скользящее окно (sliding window) позволяет вычислять агрегации (в данном случае скользящее среднее) за последние 30 секунд, обновляя результат каждые 5 секунд. Длительность окна (30 секунд) определяет объем данных для вычисления среднего, а период (5 секунд) — частоту вычислений. Триггер AfterWatermark.pastEndOfWindow() гарантирует, что результаты будут выданы после того, как все данные для данного окна будут обработаны, обеспечивая корректность вычислений. Неправильные варианты: Фиксированное окно в 5 секунд не позволит вычислить среднее за 30 секунд. Фиксированное окно в 30 секунд с триггером AfterWatermark.pastEndOfWindow().plusDelayOf(Duration.standardSeconds(5)) будет выдавать результаты только каждые 30 секунд, а не каждые 5. Скользящее окно длительностью 5 секунд не охватывает требуемые 30 секунд данных.