A transmissão de preços de ações do Pub/Sub para o Dataflow exige o cálculo de uma média móvel dos últimos 30 segundos a cada 5 segundos. Como você deve configurar as janelas e os gatilhos?

Para calcular uma média móvel dos últimos 30 segundos a cada 5 segundos, é essencial usar uma janela deslizante (sliding window). A duração da janela deve ser de 30 segundos para cobrir o período desejado, e o período de 5 segundos define a frequência com que os resultados são emitidos (a cada 5 segundos). O gatilho AfterWatermark.pastEndOfWindow() garante que os resultados sejam emitidos quando a marca d'água (watermark) ultrapassar o final da janela, indicando que todos os dados esperados para aquela janela foram processados, o que é ideal para precisão em dados de streaming. As outras opções estão incorretas porque: Uma janela fixa de 5 segundos não capturaria os dados dos últimos 30 segundos. Uma janela fixa de 30 segundos emitiria resultados apenas a cada 30 segundos, não a cada 5 segundos. Uma janela deslizante com duração de 5 segundos não cobriria os últimos 30 segundos de dados.