La diffusion en continu des cours boursiers de Pub/Sub vers Dataflow nécessite le calcul d'une moyenne mobile des 30 dernières secondes toutes les 5 secondes. Comment configurer les fenêtres et les déclencheurs ?

Pour calculer une moyenne mobile sur les 30 dernières secondes toutes les 5 secondes, une fenêtre glissante (sliding window) est la solution appropriée. La durée de la fenêtre doit être de 30 secondes pour englober les données nécessaires au calcul de la moyenne mobile. La période de la fenêtre doit être de 5 secondes pour que le calcul soit effectué toutes les 5 secondes. Le déclencheur AfterWatermark.pastEndOfWindow() est le plus courant et le plus fiable pour émettre les résultats une fois que le système est raisonnablement sûr que toutes les données pertinentes pour cette fenêtre sont arrivées, assurant ainsi des résultats précis et complets. Les fenêtres fixes ne conviennent pas car elles ne permettent pas le chevauchement nécessaire pour une moyenne mobile. Les autres options de déclenchement ou de configuration de fenêtre ne correspondent pas aux exigences de calcul d'une moyenne mobile sur 30 secondes toutes les 5 secondes.