Partição de entrada

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

Adicionado no Databricks Runtime 14.3 LTS

Sintaxe

Python

InputPartition(value)

Parâmetros

Parâmetro	Tipo	Descrição
value	Qualquer um	O valor que identifica esta partição.

Parâmetro	Tipo	Descrição
value	Qualquer um	O valor que identifica esta partição.

Notas

Esta classe deve ser serializável (picklable).

Exemplos

Utilize a implementação de partição de entrada default :

Python

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

Crie uma subclasse da classe de partição de entrada:

Python

from dataclasses import dataclass

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

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