polars.DataFrame.write_ipc_stream

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

Записать поток пакетной записи Arrow IPC.

См. раздел «Потоковый формат» на странице https://arrow.apache.org/docs/python/ipc.html.

Изменено в версии 1.1: Параметр future был переименован в compat_level.

Параметры:

file

Путь или объект, подобный файлу, доступный для записи, в который будут записаны данные пакетной записи IPC. Если задано значение None, результат возвращается в виде объекта BytesIO.

compression{‘uncompressed’, ‘lz4’, ‘zstd’}

Метод сжатия. По умолчанию — «без сжатия».

compat_level

Использовать заданный уровень совместимости при экспорте внутренних структур данных Polars.

Примеры

>>> 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)