InputPartition

Classe base che rappresenta una partizione di input restituita dal partitions() metodo di DataSourceReader.

Aggiunta in Databricks Runtime 14.3 LTS

Sintassi

InputPartition(value)

Parametri

Note

Questa classe deve essere selezionabile.

Examples

Usare l'implementazione predefinita della partizione di input:

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

Sottoclasse la classe di partizione di input:

from dataclasses import dataclass

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

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