変更（DataStreamReader）

指定されたテーブルからの行レベルの変更 (変更データキャプチャ) をストリーミングDataFrameとして返します。 現在、カタログがTableCatalog.loadChangelog()を実装しているデータソース V2 テーブルでのみサポートされています。 開始バージョンまたはタイムスタンプと処理オプションを指定するには、 option()を使用します。

構文

changes(tableName)

パラメーター

パラメーター	Type	説明
tableName	str	テーブル名。

戻り値

DataFrame

例

Python

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