ipc.new_file(sink, schema, *[, options, ...])

Create an Arrow columnar IPC file writer instance

ipc.open_file(source[, footer_offset, ...])

Create reader for Arrow file format.

ipc.new_stream(sink, schema, *[, options])

Create an Arrow columnar IPC stream writer instance

ipc.open_stream(source, *[, options, ...])

Create reader for Arrow streaming format.

ipc.read_message(source)

Read length-prefixed message from file or buffer-like object

ipc.read_record_batch(obj, Schema schema, ...)

Read RecordBatch from message, given a known schema.

ipc.get_record_batch_size(RecordBatch batch)

Return total size of serialized RecordBatch including metadata and padding.

ipc.read_tensor(source)

Read pyarrow.Tensor from pyarrow.NativeFile object from current position.

ipc.write_tensor(Tensor tensor, NativeFile dest)

Write pyarrow.Tensor to pyarrow.NativeFile object its current position.

ipc.get_tensor_size(Tensor tensor)

Return total size of serialized Tensor including metadata and padding.

ipc.IpcReadOptions(...)

Serialization options for reading IPC format.

ipc.IpcWriteOptions([metadata_version, ...])

Serialization options for the IPC format.

ipc.Message()

Container for an Arrow IPC message with metadata and optional body

ipc.MessageReader()

Interface for reading Message objects from some source (like an InputStream)

ipc.RecordBatchFileReader(source[, ...])

Class for reading Arrow record batch data from the Arrow binary file format

ipc.RecordBatchFileWriter(sink, schema, *[, ...])

Writer to create the Arrow binary file format

ipc.RecordBatchStreamReader(source, *[, ...])

Reader for the Arrow streaming binary format.

ipc.RecordBatchStreamWriter(sink, schema, *)

Writer for the Arrow streaming binary format