Akış işlem hattı (streaming pipeline) atlamalı pencereler (hopping windows) kullanıyor ancak geç gelen bazı veriler geç olarak değerlendirilmiyor ve bu da yanlış toplamalara (aggregations) neden oluyor. Geç gelen verileri doğru pencereye nasıl dahil edersiniz?

Doğru cevap, filigranlar (watermarks) kullanmak ve geç gelen verilere izin vermektir. Filigranlar, bir akış işlem hattında verilerin ne zaman tamamlandığını gösteren bir eşiktir. Geç gelen verilerin yanlış toplanmasını önlemek için, filigranlar, verilerin beklenen varış penceresini tanımlar ve bu eşiğin altında kalan geç gelen verilerin ilgili pencereye dahil edilmesini sağlar. Bu, doğru ve eksiksiz toplama işlemleri için kritiktir. Yuvarlanan pencereler (tumbling windows) çakışmayan, sabit boyutlu pencerelerdir ve geç gelen verileri ele almak için özel bir mekanizma sağlamaz. Oturum pencereleri (session windows) etkinlik tabanlıdır ve belirli bir süre boyunca hareketsizlik olduğunda kapanır; bu da geç gelen veriler için doğrudan bir çözüm değildir. Atlamalı pencereyi (hopping window) genişletmek, pencerenin boyutunu veya atlama aralığını değiştirir ancak geç gelen verilerin pencere kapanışından sonra gelmesi durumunda yine de kaçırılmasına neden olabilir.