alterações (DataStreamReader)

Devolve as alterações ao nível da linha (Captura de Dados de Alteração) da tabela especificada como DataFrame em streaming. Atualmente apenas suportado para tabelas Data Source V2 cujo catálogo implementa TableCatalog.loadChangelog(). Use option() para especificar a versão inicial ou carimbo temporal e opções de processamento.

Sintaxe

changes(tableName)

Parâmetros

Devoluções

DataFrame

Exemplos

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