polars.DataFrame.write_iceberg

DataFrame.write_iceberg(
    target: str | pyiceberg.table.Table,
    mode: Literal['append',
    'overwrite'],
) → None

Записать DataFrame в таблицу Iceberg.

Предупреждение

В настоящее время эта функция считается нестабильной. Она может быть изменена в любой момент без необходимости считать это обратно несовместимым изменением.

Параметры:

target

Имя таблицы или объект Table, представляющий таблицу Iceberg.

mode{‘append’, ‘overwrite’}

Как обрабатывать существующие данные.

• Если указано ‘append’, будут добавлены новые данные.
• Если указано ‘overwrite’, таблица будет заменена новыми данными.