InputPartition

Eine Basisklasse, die eine von der partitions() Methode zurückgegebene DataSourceReaderEingabepartition darstellt.

Hinzugefügt in Databricks Runtime 14.3 LTS

Syntax

InputPartition(value)

Parameter

Hinweise

Diese Klasse muss auswählbar sein.

Beispiele

Verwenden Sie die Standardmäßige Implementierung der Eingabepartition:

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

Unterklasse der Eingabepartitionsklasse:

from dataclasses import dataclass

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

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