InputPartition

Základní třída představující vstupní oddíl vrácený metodou partitions()DataSourceReader.

Přidání do Databricks Runtime 14.3 LTS

Syntaxe

InputPartition(value)

Parametry

Parameter	Typ	Description
value	any	Hodnota identifikující tento oddíl.

Poznámky

Tato třída musí být picklable.

Příklady

Použijte výchozí implementaci vstupního oddílu:

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

Podtřídy třídy vstupního oddílu:

from dataclasses import dataclass

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

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