pyarrow.ipc.MessageReader#
- class pyarrow.ipc.MessageReader#
Bases:
pyarrow.lib._WeakrefableInterface 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
StopIterationAt end of stream