initialOffset (SimpleDataSourceStreamReader)

Zwraca początkowe przesunięcie źródła danych przesyłania strumieniowego.

Nowe zapytanie przesyłania strumieniowego rozpoczyna odczytywanie danych z początkowego przesunięcia. Jeśli platforma Spark ponownie uruchamia istniejące zapytanie, zostanie uruchomiona ponownie z przesunięcia punktu kontrolnego, a nie początkowego.

Dodano w środowisku Databricks Runtime 15.3

Składnia

initialOffset()

Zwroty

dict

Dykt lub cykliczny dykt, którego klucz i wartość są typami pierwotnymi, w tym liczba całkowita, ciąg i wartość logiczna.

Examples

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