InputPartition

Kelas dasar yang mewakili partisi input yang dikembalikan oleh partitions() metode DataSourceReader.

Ditambahkan dalam Databricks Runtime 14.3 LTS

Sintaksis

InputPartition(value)

Parameter-parameternya

Parameter	Tipe	Deskripsi
value	apa pun	Nilai yang mengidentifikasi partisi ini.

Catatan

Kelas ini harus dapat dipilih.

Examples

Gunakan implementasi partisi input default:

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

Subkelas kelas partisi input:

from dataclasses import dataclass

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

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