pyarrow.flight.RecordBatchStream#
- class pyarrow.flight.RecordBatchStream(data_source, options=None)#
Bases:
FlightDataStreamA 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.
- options
pyarrow.ipc.IpcWriteOptions, optional Optional IPC options to control how to write the data.
- data_sourceRecordBatchReader or
Methods
Create a RecordBatchStream from a data source.