pyarrow.ipc.MessageReader#

class pyarrow.ipc.MessageReader#

Bases: _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, if you want to use memory map use MemoryMappedFile as source.
read_next_message(self)	Read next Message from the stream.

static open_stream(source)#

Open stream from source, if you want to use memory map use MemoryMappedFile as source.

Parameters:

sourcebytes/buffer-like, pyarrow.NativeFile, or file-like Python object

A readable source, like an InputStream

read_next_message(self)#

Read next Message from the stream.

Raises:

StopIteration

At end of stream