pyarrow.ipc.read_record_batch

pyarrow.ipc.read_record_batch(obj, Schema schema, DictionaryMemo dictionary_memo=None)

根据已知模式从消息中读取 RecordBatch。如果从完整的 IPC 流中读取数据，请改用 ipc.open_stream。

参数:

objMessage 或类 Buffer 对象

schemaSchema

dictionary_memoDictionaryMemo, 可选

如果消息包含字典，必须传入一个已填充的 DictionaryMemo 对象。

返回：

batchRecordBatch