InputPartition

Базовый класс, представляющий входную секцию, возвращаемую методом partitions()DataSourceReader.

Добавлено в Databricks Runtime 14.3 LTS

Синтаксис

InputPartition(value)

Параметры

Параметр	Тип	Описание
value	any	Значение, определяющее эту секцию.

Примечания

Этот класс должен быть выбран.

Примеры

Используйте реализацию входных секций по умолчанию:

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

Подкласс входного класса секционирования:

from dataclasses import dataclass

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

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