InputPartition

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

Ajouté dans Databricks Runtime 14.3 LTS

Syntaxe

InputPartition(value)

Paramètres

Remarques

Cette classe doit être picklable.

Exemples

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

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

Sous-classe de la classe de partition d’entrée :

from dataclasses import dataclass

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

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