initialOffset (DataSourceStreamReader)

Akış veri kaynağının ilk uzaklığını döndürür.

Yeni bir akış sorgusu, ilk uzaklıktan veri okumaya başlar. Spark mevcut bir sorguyu yeniden başlatıyorsa, ilk sorgu yerine denetim noktası olan uzaklıktan yeniden başlatılır.

Databricks Runtime 15.2'ye eklendi

Sözdizimi

initialOffset()

İadeler

dict

Anahtarı ve değeri Tamsayı, Dize ve Boole içeren ilkel türler olan bir dikte veya özyinelemeli dikte.

Örnekler

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