pyarrow.flight.GeneratorStream

class pyarrow.flight.GeneratorStream(schema, generator, options=None)

Bases: pyarrow._flight.FlightDataStream

A Flight data stream backed by a Python generator.

__init__()

Create a GeneratorStream from a Python generator.

Parameters

• schema (Schema) – The schema for the data to be returned.

• generator (iterator or iterable) – The generator should yield other FlightDataStream objects, Tables, RecordBatches, or RecordBatchReaders.

• options (pyarrow.ipc.IpcWriteOptions, optional) –

Methods

__init__

Create a GeneratorStream from a Python generator.

previous

pyarrow.flight.FlightServerBase

next

pyarrow.flight.RecordBatchStream