Kommentar
Åtkomst till den här sidan kräver auktorisering. Du kan prova att logga in eller ändra kataloger.
Åtkomst till den här sidan kräver auktorisering. Du kan prova att ändra kataloger.
Returnerar ändringarna på radnivå (Ändra datainsamling) från den angivna tabellen som en strömmande DataFrame. Stöds för närvarande endast för V2-tabeller med datakälla vars katalog implementerar TableCatalog.loadChangelog(). Använd option() för att ange startversionen eller tidsstämpeln och bearbetningsalternativen.
Syntax
changes(tableName)
Parameters
| Parameter | Type | Beskrivning |
|---|---|---|
tableName |
str | Tabellens namn. |
Retur
DataFrame
Exempel
spark.readStream.option("startingVersion", "10").changes("my_table")