Freigeben über


Partitionen (DataSourceStreamReader)

Gibt eine Liste von InputPartition Objekten zurück, die den Anfangs- und Endoffsets erhalten.

Jede InputPartition stellt eine Datenteilung dar, die von einer Spark-Aufgabe verarbeitet werden kann. Wird mit einem leeren Offsetbereich aufgerufen, in dem start == enddiese Methode eine leere Sequenz zurückgeben sollte.

Hinzugefügt in Databricks Runtime 15.2

Syntax

partitions(start: dict, end: dict)

Parameter

Parameter Typ Beschreibung
start Wörterbuch Der Anfangsoffset des Mikrobatchs zum Planen der Partitionierung.
end Wörterbuch Der Endoffset des Mikrobatchs zum Planen der Partitionierung.

Rückkehr

Sequence[InputPartition]

Eine Abfolge von Partitionen für diese Datenquelle. Jeder Partitionswert muss eine Instanz oder InputPartition eine Unterklasse davon sein.