initialOffset (DataSourceStreamReader)

A streamelési adatforrás kezdeti eltolását adja vissza.

Egy új streamelési lekérdezés megkezdi az adatok beolvasását a kezdeti eltolásból. Ha a Spark újraindít egy meglévő lekérdezést, az a kezdeti helyett az ellenőrzőponttal rendelkező eltolásból indul újra.

Hozzáadva a Databricks Runtime 15.2-ben

Szemantika

initialOffset()

Visszatérítések

dict

Egy diktált vagy rekurzív diktálás, amelynek kulcsa és értéke primitív típusú, beleértve az egész számot, a sztringet és a logikai értéket.

Examples

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