Lo streaming dei prezzi delle azioni da Pub/Sub a Dataflow richiede il calcolo di una media mobile degli ultimi 30 secondi ogni 5 secondi. Come si dovrebbero configurare le finestre e i trigger?
Scegli una risposta
Tocca un'opzione per controllare la tua risposta.
Risposta corretta: Utilizzare una finestra scorrevole con durata di 30 secondi e periodo di 5 secondi, ed emettere i risultati con AfterWatermark.pastEndOfWindow()..
Perché questa è la risposta
La finestra scorrevole (sliding window) con durata di 30 secondi e periodo di 5 secondi è la configurazione corretta perché consente di calcolare una media mobile degli ultimi 30 secondi ogni 5 secondi. Ogni 5 secondi, una nuova finestra di 30 secondi si apre, includendo i dati più recenti e sovrapponendosi alle finestre precedenti. Il trigger AfterWatermark.pastEndOfWindow() assicura che i risultati vengano emessi solo dopo che il watermark ha superato la fine della finestra, garantendo l'elaborazione di tutti i dati attesi. Le finestre fisse non permetterebbero il calcolo della media mobile continua richiesta. Le altre opzioni di trigger non soddisfano i requisiti di emissione ogni 5 secondi o di inclusione degli ultimi 30 secondi di dati in modo continuo.
Supera il tuo esame — senza l'infinita caccia alle risposte
Ottieni ogni domanda e spiegazione verificata per questo esame in un unico posto, e risparmia ore di preparazione. Oltre 1.000 certificazioni · Oltre 20 lingue · Inizia gratuitamente.
Supera il tuo esame più velocemente → Nessuna carta richiesta