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)

pyarrow.ipc.read_message pyarrow.ipc.get_record_batch_size