Compartilhar via


partições (DataSourceStreamReader)

Retorna uma lista de InputPartition objetos dado os deslocamentos de início e de término.

Cada InputPartition um representa uma divisão de dados que pode ser processada por uma tarefa do Spark. Quando chamado com um intervalo de deslocamento vazio em que start == end, esse método deve retornar uma sequência vazia.

Adicionado no Databricks Runtime 15.2

Sintaxe

partitions(start: dict, end: dict)

Parâmetros

Parâmetro Tipo Descrição
start dicionário O deslocamento inicial da microbatch para planejar o particionamento.
end dicionário O deslocamento final da microbatch para planejar o particionamento.

Devoluções

Sequence[InputPartition]

Uma sequência de partições para essa fonte de dados. Cada valor de partição deve ser uma instância InputPartition ou uma subclasse dele.