InputPartition

Een basisklasse die een invoerpartitie vertegenwoordigt die wordt geretourneerd door de partitions() methode van DataSourceReader.

Toegevoegd in Databricks Runtime 14.3 LTS

Syntaxis

InputPartition(value)

Parameterwaarden

Aantekeningen

Deze klasse moet kiesbaar zijn.

Examples

Gebruik de standaard implementatie van de invoerpartitie:

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

Subklasse van de invoerpartitieklasse:

from dataclasses import dataclass

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

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