polars.DataFrame.write_ipc_stream#

DataFrame.write_ipc_stream( file: str | Path | IO[bytes] | None, compression: IpcCompression = 'uncompressed', ) → BytesIO | None[source]#

Write to Arrow IPC record batch stream.

See “Streaming format” in https://arrow.apache.org/docs/python/ipc.html.

Parameters:

file: Path or writable file-like object to which the IPC record batch data will be written. If set to None, the output is returned as a BytesIO object.
compression{‘uncompressed’, ‘lz4’, ‘zstd’}: Compression method. Defaults to “uncompressed”.

Examples

>>> import pathlib
>>>
>>> df = pl.DataFrame(
...     {
...         "foo": [1, 2, 3, 4, 5],
...         "bar": [6, 7, 8, 9, 10],
...         "ham": ["a", "b", "c", "d", "e"],
...     }
... )
>>> path: pathlib.Path = dirpath / "new_file.arrow"
>>> df.write_ipc_stream(path)