返回流式处理数据源的初始偏移量。
新的流式处理查询开始从初始偏移量读取数据。 如果 Spark 正在重启现有查询，它将从检查点偏移量而不是初始偏移量重启。
在 Databricks Runtime 15.2 中添加
Syntax
initialOffset()
退货
dict
一个听写或递归听写，其键和值是基元类型，包括整数、字符串和布尔值。
示例
def initialOffset(self):
return {"partition-1": {"index": 3, "closed": True}, "partition-2": {"index": 5}}