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