createTempView

Crée une vue temporaire locale avec ce DataFrame.

Syntaxe

createTempView(name: str)

parameter

parameter	Type	Description
name	str	Nom de la vue.

parameter	Type	Description
name	str	Nom de la vue.

Notes

La durée de vie de cette table temporaire est liée au SparkSession qui a été utilisé pour créer ce DataFrame. Lance TempTableAlreadyExistsException, si le nom de la vue existe déjà dans le catalogue.

Exemples

Python

df = spark.createDataFrame([(2, "Alice"), (5, "Bob")], schema=["age", "name"])
df.createTempView("people")
spark.sql("SELECT * FROM people").show()
# +---+-----+
# |age| name|
# +---+-----+
# |  2|Alice|
# |  5|  Bob|
# +---+-----+

df.createTempView("people")  # doctest: +IGNORE_EXCEPTION_DETAIL
# Traceback (most recent call last):
# ...
# AnalysisException: "Temporary table 'people' already exists;"

spark.catalog.dropTempView("people")
# True
df.createTempView("people")

df1 = spark.createDataFrame([(1, "John"), (2, "Jane")], schema=["id", "name"])
df2 = spark.createDataFrame([(3, "Jake"), (4, "Jill")], schema=["id", "name"])
df1.createTempView("table1")
df2.createTempView("table2")
result_df = spark.table("table1").union(spark.table("table2"))
result_df.show()
# +---+----+
# | id|name|
# +---+----+
# |  1|John|
# |  2|Jane|
# |  3|Jake|
# |  4|Jill|
# +---+----+