cambios (DataStreamReader)

Devuelve los cambios de nivel de fila (Captura de datos modificados) de la tabla especificada como dataframe de streaming. Actualmente solo se admite para tablas de origen de datos V2 cuyo catálogo implementa TableCatalog.loadChangelog(). Use option() para especificar la versión inicial o las opciones de marca de tiempo y procesamiento.

Sintaxis

changes(tableName)

Parámetros

Parámetro	Tipo	Descripción
tableName	str	Nombre de la tabla.

Devoluciones

DataFrame

Ejemplos

spark.readStream.option("startingVersion", "10").changes("my_table")