partitions (DataSourceStreamReader)

Retourne une liste d’objets en fonction des InputPartition décalages de début et de fin.

Chacun InputPartition représente un fractionnement de données qui peut être traité par une tâche Spark. Lorsqu’elle est appelée avec une plage de décalage vide où start == end, cette méthode doit retourner une séquence vide.

Ajouté dans Databricks Runtime 15.2

Syntaxe

partitions(start: dict, end: dict)

Paramètres

Paramètre Type Description
start dictionnaire Décalage de début du microbatch pour planifier le partitionnement.
end dictionnaire Décalage de fin du microbatch pour planifier le partitionnement.

Retours

Sequence[InputPartition]

Séquence de partitions pour cette source de données. Chaque valeur de partition doit être une instance de InputPartition ou une sous-classe de celle-ci.