commit (DataSourceStreamReader)

通知源 Spark 已完成处理小于或等于 end 偏移量的所有数据,并且只会请求大于 end 将来的偏移量。

在 Databricks Runtime 15.2 中添加

Syntax

commit(end: dict)

参数

参数 类型 说明
end dict 流式处理查询为此源处理的最新偏移量。