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_sourceRecordBatchReader or Table

optionspyarrow.ipc.IpcWriteOptions, optional

Methods

__init__

Create a RecordBatchStream from a data source.

previous

pyarrow.flight.GeneratorStream

next

pyarrow.flight.ServerMiddlewareFactory