pyarrow.flight.RecordBatchStream

class pyarrow.flight.RecordBatchStream(data_source, options=None)

Bases: pyarrow._flight.FlightDataStream

A Flight data stream backed by RecordBatches.

__init__()

Create a RecordBatchStream from a data source.

Parameters

• data_source (RecordBatchReader or Table) –

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

Methods

__init__

Create a RecordBatchStream from a data source.

previous

pyarrow.flight.GeneratorStream

next

pyarrow.flight.ServerMiddlewareFactory