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.
pyarrow.flight.GeneratorStream pyarrow.flight.ServerMiddlewareFactory