pyarrow.MessageReader

class pyarrow.MessageReader

Bases: pyarrow.lib._Weakrefable

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

__init__(*args, **kwargs)

Initialize self. See help(type(self)) for accurate signature.

Methods

open_stream(source)

read_next_message(self)

Read next Message from the stream.

static open_stream(source)
read_next_message(self)

Read next Message from the stream.

:raises StopIteration : at end of stream: