changes (DataStreamReader)

Belirtilen tablodan satır düzeyi değişiklikleri (Veri Yakalamayı Değiştir) akış DataFrame olarak döndürür. Şu anda yalnızca kataloğu tarafından uygulanan Veri Kaynağı V2 tabloları için desteklenmektedir TableCatalog.loadChangelog(). Başlangıç sürümünü veya zaman damgasını ve işleme seçeneklerini belirtmek için kullanın option() .

Sözdizimi

changes(tableName)

Parametreler

Parametre	Türü	Açıklama
tableName	str	Tablonun adı.

İadeler

DataFrame

Örnekler

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