Utilice la transformación de ventana cuando desee acumular datos transmitidos en grupos de datos y, a continuación, procesar los conjuntos de datos. La transformaciones de ventana es una transformación pasiva.

Cuando se lee desde orígenes ilimitados, es posible que desee acumular los datos en grupos de datos delimitados para su posterior procesamiento. Para introducir intervalos delimitados en datos sin límites, utilice una transformación de ventana.

Cuando configure una transformación de ventana, defina el tipo de ventana y los límites de datos por tiempo. Para especificar los límites de datos, configure el tamaño de la ventana y el intervalo de deslizamiento de la ventana. El tamaño de la ventana define el intervalo de tiempo para el cual los datos se acumulan como un grupo de datos. El intervalo de deslizamiento define el intervalo de tiempo después del cual el grupo de datos acumulados se procesa aún más. El retraso de marca de agua define el tiempo de umbral para que un evento retrasado se acumule en un grupo de datos.

La transformación de ventana solo se puede ejecutar para las asignaciones de transmisión en el motor de Spark.

Para obtener más información acerca de la transformación de ventana, consulte la

Guía del usuario de Data Engineering Streaming

.