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.