alterações (DataStreamReader)

Retorna as alterações no nível da linha (Captura de Dados de Alteração) da tabela especificada como um DataFrame de streaming. Atualmente, só há suporte para tabelas V2 de fonte de dados cujo catálogo implementa TableCatalog.loadChangelog(). Use option() para especificar a versão inicial ou o carimbo de data/hora e as opções de processamento.

Sintaxe

changes(tableName)

Parâmetros

Devoluções

DataFrame

Exemplos

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