Modifications (DataStreamReader)
Renvoie les modifications au niveau des lignes (Change Data Capture) de la table spécifiée sous forme de DataFrame de streaming. Actuellement uniquement pris en charge pour les tables de source de données V2 dont le catalogue implémente TableCatalog.loadChangelog(). Utilisez option() pour spécifier la version ou le Timestamp de début et les options de traitement.
Syntaxe
changes(tableName)
parameter
parameter | Type | Description |
|---|---|---|
| str | Nom de la table. |
Renvoie
DataFrame
Exemples
Python
spark.readStream.option("startingVersion", "10").changes("my_table")