InputPartition

Clase base que representa una partición de entrada devuelta por el partitions() método de DataSourceReader.

Agregado en Databricks Runtime 14.3 LTS

Sintaxis

InputPartition(value)

Parámetros

Notas

Esta clase debe ser seleccionable.

Ejemplos

Use la implementación predeterminada de la partición de entrada:

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

Subclase la clase de partición de entrada:

from dataclasses import dataclass

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

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