Nota
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare ad accedere o modificare le directory.
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare a modificare le directory.
Restituisce le modifiche a livello di riga (Change Data Capture) dalla tabella specificata come dataframe di streaming. Attualmente supportato solo per le tabelle V2 dell'origine dati il cui catalogo implementa TableCatalog.loadChangelog(). Usare option() per specificare la versione iniziale o il timestamp e le opzioni di elaborazione.
Sintassi
changes(tableName)
Parametri
| Parametro | Tipo | Descrizione |
|---|---|---|
tableName |
str | Nome della tabella. |
Restituzioni
DataFrame
Examples
spark.readStream.option("startingVersion", "10").changes("my_table")