Notiz
Zougrëff op dës Säit erfuerdert Autorisatioun. Dir kënnt probéieren, Iech unzemellen oder Verzeechnesser ze änneren.
Zougrëff op dës Säit erfuerdert Autorisatioun. Dir kënnt probéieren, Verzeechnesser ze änneren.
Returns the row-level changes (Change Data Capture) from the specified table as a streaming DataFrame. Currently only supported for Data Source V2 tables whose catalog implements TableCatalog.loadChangelog(). Use option() to specify the starting version or timestamp and processing options.
Syntax
changes(tableName)
Parameters
| Parameter | Type | Description |
|---|---|---|
tableName |
str | Name of the table. |
Returns
DataFrame
Examples
spark.readStream.option("startingVersion", "10").changes("my_table")