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

• obj (Message or Buffer-like) –

• schema (Schema) –

• dictionary_memo (DictionaryMemo, optional) – If message contains dictionaries, must pass a populated DictionaryMemo

Returns

batch (RecordBatch)