oddíly (DataSourceStreamReader)

Vrátí seznam InputPartition objektů s daným počátečním a koncovým posunem.

Každá InputPartition představuje rozdělení dat, které je možné zpracovat jedním úkolem Sparku. Při zavolání s prázdným rozsahem posunu, kde start == end, by tato metoda měla vrátit prázdnou sekvenci.

Přidáno do Databricks Runtime 15.2

Syntaxe

partitions(start: dict, end: dict)

Parametry

Parameter Typ Description
start slovník Počáteční posun mikrobatchu k plánování dělení.
end slovník Koncový posun mikrobatchu k plánování dělení.

Návraty

Sequence[InputPartition]

Posloupnost oddílů pro tento zdroj dat. Každá hodnota oddílu musí být instancí InputPartition nebo podtřídou oddílu.