変更（DataStreamReader）
指定されたテーブルからの行レベルの変更 (変更データキャプチャ) をストリーミングDataFrameとして返します。 現在、カタログがTableCatalog.loadChangelog()を実装しているデータソース V2 テーブルでのみサポートされています。 開始バージョンまたはタイムスタンプと処理オプションを指定するには、 option()を使用します。
構文
changes(tableName)
パラメーター
パラメーター | Type | 説明 |
|---|---|---|
| str | テーブル名。 |
戻り値
DataFrame
例
Python
spark.readStream.option("startingVersion", "10").changes("my_table")