Remarque
L’accès à cette page nécessite une autorisation. Vous pouvez essayer de vous connecter ou de modifier des répertoires.
L’accès à cette page nécessite une autorisation. Vous pouvez essayer de modifier des répertoires.
Retourne les modifications au niveau des lignes (Capture de données modifiées) de la table spécifiée en tant que DataFrame de diffusion en continu. Actuellement uniquement pris en charge pour les tables V2 de source de données dont le catalogue implémente TableCatalog.loadChangelog(). Permet option() de spécifier la version de départ ou l’horodatage et les options de traitement.
Syntaxe
changes(tableName)
Paramètres
| Paramètre | Type | Description |
|---|---|---|
tableName |
str | Nom de la table. |
Retours
DataFrame
Exemples
spark.readStream.option("startingVersion", "10").changes("my_table")