pyarrow.flight.RecordBatchStream

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

Bases: FlightDataStream

A Flight data stream backed by RecordBatches.

The remainder of this DoGet request will be handled in C++, without having to acquire the GIL.

__init__()

Create a RecordBatchStream from a data source.

Parameters:

data_sourceRecordBatchReader or Table

The data to stream to the client.

optionspyarrow.ipc.IpcWriteOptions, optional

Optional IPC options to control how to write the data.

Methods

__init__

Create a RecordBatchStream from a data source.