将指定表中的行级更改（更改数据捕获）作为流式处理数据帧返回。 目前仅支持其目录实现的 TableCatalog.loadChangelog()数据源 V2 表。 用于 option() 指定起始版本或时间戳和处理选项。
Syntax
changes(tableName)
参数
| 参数 | 类型 | 说明 |
|---|---|---|
tableName |
str | 表格名称 |
退货
DataFrame
示例
spark.readStream.option("startingVersion", "10").changes("my_table")