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

previous

pyarrow.ipc.read_message

next

pyarrow.ipc.get_record_batch_size