InputPartition

Une classe de base représentant une partition d'entrée retournée par la méthode partitions() de DataSourceReader.

Ajouté dans Databricks Runtime 14.3 LTS

Syntaxe

Python

InputPartition(value)

parameter

parameter	Type	Description
value	tout	La valeur identifiant cette partition.

parameter	Type	Description
value	tout	La valeur identifiant cette partition.

Notes

Cette classe doit être sérialisable.

Exemples

Utilisez l’implémentation de partition d’entrée default :

Python

def partitions(self):
    return [InputPartition(1)]

Sous-classez la classe de partition d'entrée :

Python

from dataclasses import dataclass

@dataclass
class RangeInputPartition(InputPartition):
    start: int
    end: int

def partitions(self):
    return [RangeInputPartition(1, 3), RangeInputPartition(4, 6)]