ストリーミング データ ソースの初期オフセットを返します。
新しいストリーミング クエリは、最初のオフセットからデータの読み取りを開始します。 Spark が既存のクエリを再起動すると、最初のクエリではなく、チェックポイント処理されたオフセットから再起動されます。
Databricks Runtime 15.2 で追加されました
構文
initialOffset()
返品
dict
整数、文字列、ブール値を含むプリミティブ型のキーと値を持つディクテーションまたは再帰ディクテーション。
例示
def initialOffset(self):
return {"partition-1": {"index": 3, "closed": True}, "partition-2": {"index": 5}}