read (DataSourceStreamReader)

Belirli bir bölüm için veri oluşturur ve demetlerin veya satırların yineleyicisini döndürür.

Bu yöntem, verileri okumak için bölüm başına bir kez çağrılır. Bu yöntemi uygulamak, akış okuyucular için gereklidir. Bu yöntemdeki veri kaynağından veri okumak için gerekli serileştirilebilir olmayan kaynakları başlatabilirsiniz.

Databricks Runtime 15.2'ye eklendi

Sözdizimi

read(partition: InputPartition)

Parametreler

Parametre Türü Açıklama
partition InputPartition Okunacak bölüm. tarafından partitions()döndürülen bölüm değerlerinden biri olmalıdır.

İadeler

Iterator[Tuple] veya Iterator[RecordBatch]

Tanımlama demetlerinin veya satırların yineleyicisi. Her tanımlama grubu veya satır, son DataFrame'deki bir satıra dönüştürülür. Veri kaynağı destekliyorsa PyArrow RecordBatch nesnelerinin yineleyicisini de döndürebilir.

Notlar

Bu yöntem statik ve durum bilgisi olmayan bir yöntemdir. Değiştirilebilir sınıf üyelerine erişmeyin veya farklı çağrıları arasında bellek içi durumu tutmayın read().