partisi (DataSourceStreamReader)

Mengembalikan daftar InputPartition objek yang diberikan offset awal dan akhir.

Masing-masing InputPartition mewakili pemisahan data yang dapat diproses oleh satu tugas Spark. Ketika dipanggil dengan rentang offset kosong di mana start == end, metode ini harus mengembalikan urutan kosong.

Ditambahkan dalam Databricks Runtime 15.2

Sintaksis

partitions(start: dict, end: dict)

Parameter-parameternya

Parameter	Tipe	Deskripsi
start	kamus	Offset awal mikrobatch untuk merencanakan partisi.
end	kamus	Offset akhir mikrobatch untuk merencanakan partisi.

Pengembalian Barang

Sequence[InputPartition]

Urutan partisi untuk sumber data ini. Setiap nilai partisi harus berupa instans InputPartition atau subkelasnya.