Notitie
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen u aan te melden of de directory te wijzigen.
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen de mappen te wijzigen.
Retourneert de wijzigingen op rijniveau (Change Data Capture) uit de opgegeven tabel als een streaming DataFrame. Momenteel alleen ondersteund voor gegevensbron V2-tabellen waarvan de catalogus wordt geïmplementeerd TableCatalog.loadChangelog(). Gebruik option() deze indeling om de beginversie of tijdstempel en verwerkingsopties op te geven.
Syntaxis
changes(tableName)
Parameterwaarden
| Kenmerk | Typ | Beschrijving |
|---|---|---|
tableName |
str | Naam van de tabel. |
Retouren
DataFrame
Examples
spark.readStream.option("startingVersion", "10").changes("my_table")