pyarrow.flight.RecordBatchStream#
- class pyarrow.flight.RecordBatchStream(data_source, options=None)#
基类:
FlightDataStream一个由 RecordBatch 提供支持的 Flight 数据流。
此 DoGet 请求的其余部分将在 C++ 中处理，无需获取 GIL。
- __init__()#
从数据源创建 RecordBatchStream。
- 参数:
- data_sourceRecordBatchReader 或
Table 要流式传输到客户端的数据。
- options
pyarrow.ipc.IpcWriteOptions，可选 可选的 IPC 选项，用于控制如何写入数据。
- data_sourceRecordBatchReader 或
方法
从数据源创建 RecordBatchStream。