pyarrow.ipc.read_record_batch

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

Read RecordBatch from message, given a known schema. If reading data from a complete IPC stream, use ipc.open_stream instead

Parameters:

objMessage or Buffer-like

schemaSchema

dictionary_memoDictionaryMemo, optional

If message contains dictionaries, must pass a populated DictionaryMemo

Returns:

batchRecordBatch