Nóta
Teastaíonn údarú chun rochtain a fháil ar an leathanach seo. Is féidir leat triail a bhaint as shíniú isteach nó eolairí a athrú.
Teastaíonn údarú chun rochtain a fháil ar an leathanach seo. Is féidir leat triail a bhaint as eolairí a athrú.
Returns the initial offset of the streaming data source.
A new streaming query starts reading data from the initial offset. If Spark is restarting an existing query, it will restart from the checkpointed offset rather than the initial one.
Added in Databricks Runtime 15.2
Syntax
initialOffset()
Returns
dict
A dict or recursive dict whose key and value are primitive types, which includes Integer, String, and Boolean.
Examples
def initialOffset(self):
return {"partition-1": {"index": 3, "closed": True}, "partition-2": {"index": 5}}