pyarrow.ipc.MessageReader¶
-
class
pyarrow.ipc.MessageReader¶ Bases:
pyarrow.lib._WeakrefableInterface for reading Message objects from some source (like an InputStream)
-
__init__(*args, **kwargs)¶ Initialize self. See help(type(self)) for accurate signature.
Methods
__init__(*args, **kwargs)Initialize self.
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:
-