daft.DataFrame.write_iceberg

DataFrame.write_iceberg(table: pyiceberg.table.Table, mode: str = 'append', io_config: Optional[IOConfig] = None) → DataFrame

Writes the DataFrame to an Iceberg table, returning a new DataFrame with the operations that occurred.

Can be run in either append or overwrite mode which will either appends the rows in the DataFrame or will delete the existing rows and then append the DataFrame rows respectively.

Note

This call is blocking and will execute the DataFrame when called

Parameters:

• table (pyiceberg.table.Table) – Destination PyIceberg Table to write dataframe to.

• mode (str, optional) – Operation mode of the write. append or overwrite Iceberg Table. Defaults to “append”.

• io_config (IOConfig, optional) – A custom IOConfig to use when accessing Iceberg object storage data. If provided, configurations set in table are ignored.

Returns:

The operations that occurred with this write.

Return type:

DataFrame

• Get Started
• User Guide
• Github
• Blog
• Community