Nota
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare ad accedere o modificare le directory.
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare a modificare le directory.
Restituisce un elenco di InputPartition oggetti in base agli offset iniziale e finale.
Ognuno InputPartition rappresenta una suddivisione dei dati che può essere elaborata da un'attività Spark. Quando viene chiamato con un intervallo di offset vuoto in cui start == end, questo metodo deve restituire una sequenza vuota.
Aggiunta in Databricks Runtime 15.2
Sintassi
partitions(start: dict, end: dict)
Parametri
| Parametro | Tipo | Descrizione |
|---|---|---|
start |
dizionario | Offset iniziale del microbatch per pianificare il partizionamento. |
end |
dizionario | Offset finale del microbatch per pianificare il partizionamento. |
Restituzioni
Sequence[InputPartition]
Sequenza di partizioni per questa origine dati. Ogni valore di partizione deve essere un'istanza di InputPartition o una sottoclasse.