read (DataSourceStreamReader)

Vygeneruje data pro daný oddíl a vrátí iterátor řazených kolekcí členů nebo řádků.

Tato metoda se vyvolá jednou pro každý oddíl pro čtení dat. Implementace této metody se vyžaduje pro čtenáře streamu. V rámci této metody můžete inicializovat všechny ne serializovatelné prostředky potřebné ke čtení dat ze zdroje dat.

Přidáno do Databricks Runtime 15.2

Syntaxe

read(partition: InputPartition)

Parametry

Parameter Typ Description
partition InputPartition Oddíl, který se má přečíst. Musí to být jedna z hodnot oddílů vrácených partitions().

Návraty

Iterator[Tuple] nebo Iterator[RecordBatch]

Iterátor řazených kolekcí členů nebo řádků. Každá řazená kolekce členů nebo řádek se převede na řádek v konečném datovém rámci. Může také vrátit iterátor objektů PyArrow RecordBatch , pokud ho zdroj dat podporuje.

Poznámky

Tato metoda je statická a bezstavová. Nepřistupujte ke členům proměnlivé třídy nebo udržujte stav v paměti mezi různými vyvoláním read().