Pub/Sub'dan Dataflow'a akan hisse senedi fiyatları, her 5 saniyede bir son 30 saniyenin hareketli ortalamasını hesaplamayı gerektiriyor. Pencereleri ve tetikleyicileri nasıl yapılandırmalısınız?

Doğru cevap, 30 saniyelik bir süreye ve 5 saniyelik bir periyoda sahip kayan bir pencere kullanmaktır. Kayan pencereler (sliding windows), belirli bir süre (30 saniye) boyunca verileri analiz ederken, bu pencereyi düzenli aralıklarla (5 saniye) ileri kaydırarak sürekli olarak yeni sonuçlar üretmek için idealdir. Bu, her 5 saniyede bir son 30 saniyenin hareketli ortalamasını hesaplama gereksinimini karşılar. AfterWatermark.pastEndOfWindow() tetikleyicisi, penceredeki tüm verilerin (su işaretine göre) işlendiğinden emin olduktan sonra sonuçları yayınlayarak doğru ve eksiksiz hesaplamalar sağlar. Diğer seçenekler yanlıştır çünkü: Sabit pencereler (fixed windows) bu tür sürekli hareketli ortalama hesaplamaları için uygun değildir; verileri ayrık, çakışmayan bloklara bölerler. AfterProcessingTime tetikleyicileri, olay zamanı yerine işleme zamanına dayandığı için gecikmeli verilerde sorunlara yol açabilir ve genellikle daha az tercih edilir.