La transmisión de precios de acciones desde Pub/Sub a Dataflow requiere calcular un promedio móvil de los últimos 30 segundos cada 5 segundos. ¿Cómo se deben configurar las ventanas y los disparadores?

La respuesta correcta es usar una ventana deslizante con duración de 30 segundos y período de 5 segundos, y emitir resultados con AfterWatermark.pastEndOfWindow(). Una ventana deslizante (sliding window) es ideal para calcular promedios móviles porque permite que las ventanas se superpongan. La "duración de 30 segundos" asegura que cada ventana considere los últimos 30 segundos de datos, mientras que el "período de 5 segundos" significa que se emite un nuevo resultado cada 5 segundos, cumpliendo con el requisito. El disparador AfterWatermark.pastEndOfWindow() es el estándar para emitir resultados una vez que la marca de agua ha superado el final de la ventana, garantizando la completitud de los datos dentro de esa ventana. Las ventanas fijas no son adecuadas para promedios móviles que requieren superposición. Las opciones con AfterProcessingTime son menos fiables para la completitud de datos en un entorno de streaming.