changes (DataStreamReader)

Vrátí změny na úrovni řádků (Change Data Capture) ze zadané tabulky jako streamovaný datový rámec. V současné době je podporován pouze pro tabulky zdroje dat V2, jejichž katalog implementuje TableCatalog.loadChangelog(). Slouží option() k určení počáteční verze nebo časového razítka a možností zpracování.

Syntaxe

changes(tableName)

Parametry

Parameter	Typ	Description
tableName	str	Název tabulky.

Návraty

DataFrame

Příklady

spark.readStream.option("startingVersion", "10").changes("my_table")