changes (DataStreamReader)

Zwraca zmiany na poziomie wiersza (Zmień przechwytywanie danych) z określonej tabeli jako przesyłania strumieniowego ramki danych. Obecnie obsługiwane są tylko tabele źródła danych w wersji 2, których wykaz implementuje TableCatalog.loadChangelog()element . Użyj option() polecenia , aby określić wersję początkową lub znacznik czasu i opcje przetwarzania.

Składnia

changes(tableName)

Parametry

Parameter	Typ	Opis
tableName	str	Nazwa tabeli.

Zwroty

DataFrame

Examples

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