Przesyłanie strumieniowe cen akcji z Pub/Sub do Dataflow wymaga obliczania średniej ruchomej z ostatnich 30 sekund co 5 sekund. Jak należy skonfigurować okna i wyzwalacze?

Prawidłowa odpowiedź to okno przesuwne (sliding window) o długości 30 sekund i okresie 5 sekund, emitujące wyniki za pomocą AfterWatermark.pastEndOfWindow(). Okno przesuwne o długości 30 sekund zapewnia, że obliczenia średniej ruchomej obejmują dane z ostatnich 30 sekund. Okres 5 sekund (czyli co ile sekund okno się przesuwa) gwarantuje, że wynik jest obliczany co 5 sekund, zgodnie z wymaganiem. AfterWatermark.pastEndOfWindow() jest standardowym wyzwalaczem do emitowania wyników po przetworzeniu wszystkich danych w danym oknie, co jest odpowiednie dla tego scenariusza. Pozostałe opcje są nieprawidłowe: Stałe okno (fixed window) o długości 5 sekund nie pozwoli na obliczenie średniej z ostatnich 30 sekund. Stałe okno (fixed window) o długości 30 sekund z wyzwalaczem AfterWatermark.pastEndOfWindow().plusDelayOf(Duration.standardSeconds(5)) obliczałoby średnią co 30 sekund, a nie co 5 sekund. Okno przesuwne (sliding window) o długości 5 sekund nie obejmowałoby danych z ostatnich 30 sekund.