變更(DataStreamReader)

從指定資料表回傳列層級的變更(變更資料擷取)作為串流資料框架。 目前僅支援資料來源 V2 表格,其目錄實作 TableCatalog.loadChangelog()。 用 option() 來指定起始版本或時間戳記及處理選項。

語法

changes(tableName)

參數

參數 類型 說明
tableName str 數據表的名稱。

退貨

DataFrame

Examples

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