pyarrow.read_record_batch

pyarrow.read_record_batch(obj, Schema schema)

Read RecordBatch from message, given a known schema

Parameters:

• obj (Message or Buffer-like) –
• schema (Schema) –

Returns:

batch (RecordBatch)