initialOffset (SimpleDataSourceStreamReader)

ストリーミングデータソースの初期オフセットを返します。

新しいストリーミングクエリは、初期オフセットからデータの読み取りを開始します。Sparkが既存のクエリを再開する場合、最初のオフセットではなく、チェックポイントのオフセットから再開します。

Databricks Runtime 15.3で追加されました

構文

initialOffset()

戻り値

dict

キーと値がプリミティブ型である辞書または再帰辞書。プリミティブ型には、Integer、S、 Boolean含まれます。

例

Python

def initialOffset(self):
    return {"partition-1": {"index": 3, "closed": True}, "partition-2": {"index": 5}}