initialOffset (SimpleDataSourceStreamReader)

Mengembalikan offset awal sumber data streaming.

Kueri streaming baru mulai membaca data dari offset awal. Jika Spark memulai ulang kueri yang ada, Spark akan memulai ulang dari offset yang di-checkpoint daripada yang awal.

Ditambahkan dalam Databricks Runtime 15.3

Sintaksis

initialOffset()

Pengembalian Barang

dict

Dict atau dict rekursif yang kunci dan nilainya adalah jenis primitif, yang mencakup Bilangan bulat, String, dan Boolean.

Examples

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