pyspark.sql.DataFrame.createOrReplaceTempView#
- DataFrame.createOrReplaceTempView(name)[source]#
- Creates or replaces a local temporary view with this - DataFrame.- New in version 2.0.0. - Changed in version 3.4.0: Supports Spark Connect. - Parameters
- namestr
- Name of the view. 
 
 - Notes - The lifetime of this temporary table is tied to the - SparkSessionthat was used to create this- DataFrame.- Examples - Example 1: Creating a local temporary view named ‘people’. - >>> df = spark.createDataFrame([(2, "Alice"), (5, "Bob")], schema=["age", "name"]) >>> df.createOrReplaceTempView("people") - Example 2: Replacing the local temporary view. - >>> df2 = df.filter(df.age > 3) >>> # Replace the local temporary view with the filtered DataFrame >>> df2.createOrReplaceTempView("people") >>> # Query the temporary view >>> df3 = spark.sql("SELECT * FROM people") >>> # Check if the DataFrames are equal ... assert sorted(df3.collect()) == sorted(df2.collect()) - Example 3: Dropping the temporary view. - >>> # Drop the local temporary view ... spark.catalog.dropTempView("people") True