partitions (DataSourceStreamReader)

Başlangıç ve bitiş uzaklıkları verilen nesnelerin listesini InputPartition döndürür.

Her InputPartition biri, bir Spark görevi tarafından işlenebilen bir veri bölmeyi temsil eder. burada start == endboş bir uzaklık aralığıyla çağrıldığında, bu yöntem boş bir dizi döndürmelidir.

Databricks Runtime 15.2'ye eklendi

Sözdizimi

partitions(start: dict, end: dict)

Parametreler

Parametre Türü Açıklama
start Dict Bölümleme planlamak için mikrobatch'in başlangıç uzaklığı.
end Dict Bölümlemesini planlamak için mikrobatch'in bitiş uzaklığı.

İadeler

Sequence[InputPartition]

Bu veri kaynağı için bölüm dizisi. Her bölüm değeri, InputPartition bir örneği veya alt sınıfı olmalıdır.