yggdrasil.pickle.ser.pyarrow

pyarrow

ArrowSerialized dataclass

ArrowSerialized(head: Header, data: IO)

Bases: Serialized[TArrow], Generic[TArrow]

decode_arrow_buffer

decode_arrow_buffer() -> pa.Buffer

Return payload as a pyarrow.Buffer suitable for Arrow IPC reads.

This is only truly zero-copy when: - self.codec == CODEC_NONE - the underlying Serialized payload can be exposed without materializing a new Python bytes object.

With the current base Serialized API, we can only guarantee the IPC read side is Arrow-native; true end-to-end zero-copy may still require a base layer hook that exposes the raw payload buffer directly.

module_and_name staticmethod

module_and_name(obj: Any, *, fallback: str = '') -> tuple[str, str]

Return (module, qualname) for obj.

Robust across Python objects, including many C-extension / PyArrow objects where module may be missing or misleading.