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

Devoluciones

DataFrame

Ejemplos

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