InputPartition

yöntemi partitions()tarafından DataSourceReader döndürülen giriş bölümünü temsil eden bir temel sınıf.

Databricks Runtime 14.3 LTS'ye eklendi

Sözdizimi

InputPartition(value)

Parametreler

Notlar

Bu sınıf picklable olmalıdır.

Örnekler

Varsayılan giriş bölümü uygulamasını kullanın:

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

Giriş bölümü sınıfını alt sınıfa yazın:

from dataclasses import dataclass

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

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