daft.DataFrame.write_iceberg

DataFrame.write_iceberg(table: IcebergTable, mode: str = 'append') → 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 (IcebergTable) – Destination Iceberg Table to write dataframe to.

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

Returns:

The operations that occurred with this write.

Return type:

DataFrame

• Get Started
• Documentation
• Github
• Blog
• Community