pyspark.sql.DataFrame.createOrReplaceTempView¶

DataFrame.createOrReplaceTempView(name: str) → None[source]¶

Creates or replaces a local temporary view with this DataFrame.

The lifetime of this temporary table is tied to the SparkSession that was used to create this DataFrame.

New in version 2.0.0.

Changed in version 3.4.0: Supports Spark Connect.

Parameters

namestr: Name of the view.

Examples

Create a local temporary view named ‘people’.

>>> df = spark.createDataFrame([(2, "Alice"), (5, "Bob")], schema=["age", "name"])
>>> df.createOrReplaceTempView("people")

Replace the local temporary view.

>>> df2 = df.filter(df.age > 3)
>>> df2.createOrReplaceTempView("people")
>>> df3 = spark.sql("SELECT * FROM people")
>>> sorted(df3.collect()) == sorted(df2.collect())
True
>>> spark.catalog.dropTempView("people")
True

pyspark.sql.DataFrame.createOrReplaceGlobalTempView

pyspark.sql.DataFrame.createTempView