alterações (DataStreamReader)
Retorna as alterações em nível de linha (captura de dados de alterações (CDC)) da tabela especificada como uma transmissão DataFrame. Atualmente, apenas é suportado para tabelas fonte de dados V2 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
Parâmetro | Tipo | Descrição |
|---|---|---|
| str | Nome da tabela. |
Devoluções
DataFrame
Exemplos
Python
spark.readStream.option("startingVersion", "10").changes("my_table")