Kommentar
Åtkomst till den här sidan kräver auktorisering. Du kan prova att logga in eller ändra kataloger.
Åtkomst till den här sidan kräver auktorisering. Du kan prova att ändra kataloger.
En basklass som representerar en indatapartition som returneras av partitions() metoden DataSourceReader.
Har lagts till i Databricks Runtime 14.3 LTS
Syntax
InputPartition(value)
Parameters
| Parameter | Type | Beskrivning |
|---|---|---|
value |
någon | Värdet som identifierar den här partitionen. |
Notes
Den här klassen måste vara picklable.
Exempel
Använd standardimplementeringen för indatapartition:
def partitions(self):
return [InputPartition(1)]
Underklassa indatapartitionsklassen:
from dataclasses import dataclass
@dataclass
class RangeInputPartition(InputPartition):
start: int
end: int
def partitions(self):
return [RangeInputPartition(1, 3), RangeInputPartition(4, 6)]