pyspark.sql.DataFrame.writeTo

DataFrame.writeTo(table: str) → pyspark.sql.readwriter.DataFrameWriterV2

Create a write configuration builder for v2 sources.

This builder is used to configure and execute write operations.

For example, to append or create or replace existing tables.

Examples

>>> df.writeTo("catalog.db.table").append()  
>>> df.writeTo(                              
...     "catalog.db.table"
... ).partitionedBy("col").createOrReplace()