pyspark.sql.DataFrame.writeTo

DataFrame.writeTo(table)

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.

New in version 3.1.0.

Examples

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

pyspark.sql.DataFrame.writeStream pyspark.sql.DataFrame.to_pandas_on_spark