perubahan (DataStreamReader)

Mengembalikan perubahan tingkat baris (Ubah Pengambilan Data) dari tabel yang ditentukan sebagai DataFrame streaming. Saat ini hanya didukung untuk tabel Sumber Data V2 yang katalognya mengimplementasikan TableCatalog.loadChangelog(). Gunakan option() untuk menentukan versi awal atau tanda waktu dan opsi pemrosesan.

Sintaksis

changes(tableName)

Parameter-parameternya

Parameter	Tipe	Deskripsi
tableName	str	Nama tabel tersebut.

Pengembalian Barang

DataFrame

Examples

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