Notatka
Dostęp do tej strony wymaga autoryzacji. Może spróbować zalogować się lub zmienić katalogi.
Dostęp do tej strony wymaga autoryzacji. Możesz spróbować zmienić katalogi.
Generuje dane dla danej partycji i zwraca iterator krotki lub wierszy.
Ta metoda jest wywoływana raz na partycję, aby odczytać dane. Implementacja tej metody jest wymagana dla czytników strumieni. W ramach tej metody można zainicjować wszystkie zasoby nieseralnie możliwe do serializacji wymagane do odczytu danych ze źródła danych.
Dodano w środowisku Databricks Runtime 15.2
Składnia
read(partition: InputPartition)
Parametry
| Parameter | Typ | Opis |
|---|---|---|
partition |
InputPartition | Partycja do odczytania. Musi być jedną z wartości partycji zwracanych przez partitions()element . |
Zwroty
Iterator[Tuple] lub Iterator[RecordBatch]
Iterator krotki lub wierszy. Każda krotka lub wiersz zostaną przekonwertowane na wiersz w końcowej ramce danych. Może również zwrócić iterator obiektów PyArrow RecordBatch , jeśli źródło danych go obsługuje.
Notatki
Ta metoda jest statyczna i bezstanowa. Nie należy uzyskiwać dostępu do składowych klas modyfikowalnych ani zachowywać stanu w pamięci między różnymi wywołaniami read()klasy .