Das Streamen von Aktienkursen von Pub/Sub nach Dataflow erfordert die Berechnung eines gleitenden Durchschnitts der letzten 30 Sekunden alle 5 Sekunden. Wie sollten Sie Fenster und Trigger konfigurieren?
Wählen Sie eine Antwort
Tippen Sie auf eine Option, um Ihre Antwort zu überprüfen.
Richtige Antwort: Verwenden Sie ein gleitendes Fenster mit einer Dauer von 30 Sekunden und einer Periode von 5 Sekunden, und geben Sie Ergebnisse mit AfterWatermark.pastEndOfWindow() aus..
Warum dies die Antwort ist
Die Aufgabe erfordert die Berechnung eines gleitenden Durchschnitts über die letzten 30 Sekunden, der alle 5 Sekunden aktualisiert wird. Ein gleitendes Fenster (Sliding Window) ist hierfür die korrekte Wahl. Die Dauer des Fensters sollte 30 Sekunden betragen, um die letzten 30 Sekunden Daten zu erfassen. Die Periode des Fensters sollte 5 Sekunden betragen, um alle 5 Sekunden eine neue Berechnung auszulösen. Der Trigger AfterWatermark.pastEndOfWindow() stellt sicher, dass die Ergebnisse ausgegeben werden, sobald das Watermark das Ende des Fensters überschreitet, was für eine vollständige und korrekte Aggregation wichtig ist. Feste Fenster (Fixed Windows) sind ungeeignet, da sie sich nicht überlappen und somit keinen gleitenden Durchschnitt ermöglichen. Trigger, die auf AfterProcessingTime basieren, sind weniger zuverlässig für korrekte Ergebnisse in Bezug auf Event-Zeit, da sie die Verarbeitungszeit und nicht die Event-Zeit berücksichtigen.
Bestehen Sie Ihre Prüfung – ohne endlose Antwortsuche
Erhalten Sie jede verifizierte Frage und Erklärung für diese Prüfung an einem Ort und sparen Sie Stunden der Vorbereitung. Über 1.000 Zertifizierungen · Über 20 Sprachen · Kostenloser Start.
Bestehen Sie Ihre Prüfung schneller → Keine Karte erforderlich