Un pipeline de streaming utilise des fenêtres glissantes (hopping windows), mais certaines données arrivant en retard ne sont pas traitées comme telles, ce qui entraîne des agrégations incorrectes. Comment capturer les données en retard dans la bonne fenêtre ?
Choisissez une réponse
Appuyez sur une option pour vérifier votre réponse.
Bonne réponse : Utilisez des filigranes (watermarks) pour définir la fenêtre d'arrivée des données attendue. Autorisez les données en retard à mesure qu'elles arrivent..
Pourquoi c'est la réponse
Les filigranes (watermarks) sont la solution standard pour gérer les données en retard dans les pipelines de streaming. Ils définissent une limite de temps au-delà de laquelle les données sont considérées comme en retard. En permettant aux données en retard d'être traitées si elles arrivent avant le filigrane, vous assurez leur inclusion dans la fenêtre correcte. Les fenêtres fixes (tumbling windows) ne se chevauchent pas et ne résolvent pas le problème des données en retard. Les fenêtres de session (session windows) sont basées sur l'activité de l'utilisateur et ne gèrent pas directement les retards d'arrivée. Élargir la fenêtre glissante (hopping window) pourrait inclure plus de données en retard, mais ne garantit pas leur attribution à la fenêtre d'origine et peut augmenter la latence.
Réussissez votre examen — sans la chasse aux réponses interminable
Obtenez toutes les questions et explications vérifiées pour cet examen en un seul endroit, et économisez des heures de préparation. Plus de 1 000 certifications · Plus de 20 langues · Gratuit pour commencer.
Réussissez votre examen plus rapidement → Pas de carte requise