particiones (DataSourceStreamReader)

Devuelve una lista de InputPartition objetos dados los desplazamientos inicial y final.

Cada InputPartition representa una división de datos que se puede procesar mediante una tarea de Spark. Cuando se llama a con un intervalo de desplazamiento vacío donde start == end, este método debe devolver una secuencia vacía.

Agregado en Databricks Runtime 15.2

Sintaxis

partitions(start: dict, end: dict)

Parámetros

Parámetro	Tipo	Descripción
start	diccionario	Desplazamiento inicial del microbatch para planear la creación de particiones.
end	diccionario	Desplazamiento final del microbatch para planear la creación de particiones.

Devoluciones

Sequence[InputPartition]

Secuencia de particiones para este origen de datos. Cada valor de partición debe ser una instancia de InputPartition o una subclase de él.