pyarrow.ipc.MessageReader

class pyarrow.ipc.MessageReader

Bases: pyarrow.lib._Weakrefable

Interface for reading Message objects from some source (like an InputStream)

__init__(*args, **kwargs)

Methods

__init__(*args, **kwargs)
open_stream(source)	Open stream from source.
read_next_message(self)	Read next Message from the stream.

static open_stream(source)

Open stream from source.

Parameters

source

A readable source, like an InputStream

read_next_message(self)

Read next Message from the stream.

Raises

StopIteration

At end of stream

previous

pyarrow.ipc.Message

next

pyarrow.ipc.RecordBatchFileReader