pyarrow.Message

class pyarrow.Message

Bases: object

Container for an Arrow IPC message with metadata and optional body

__init__()

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

Methods

equals(self, Message other) Returns True if the message contents (metadata and body) are identical
serialize(self[, memory_pool]) Write message as encapsulated IPC message
body
equals(self, Message other)

Returns True if the message contents (metadata and body) are identical

Parameters:other (Message) –
Returns:are_equal (bool)
metadata
serialize(self, memory_pool=None)

Write message as encapsulated IPC message

Parameters:memory_pool (MemoryPool, default None) – Uses default memory pool if not specified
Returns:serialized (Buffer)
type