InputPartition

Uma classe base que representa uma partição de entrada devolvida pelo partitions() método de DataSourceReader.

Adicionado no Databricks Runtime 14.3 LTS

Sintaxe

InputPartition(value)

Parâmetros

Notes

Esta aula tem de ser fácil de picklear.

Exemplos

Use a implementação padrão da partição de entrada:

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

Subclasse a classe de partição de entrada:

from dataclasses import dataclass

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

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