sparksql 中 create temporary table as
时间: 2024-04-10 21:26:47 浏览: 146
在 Spark SQL 中,使用 "CREATE TEMPORARY TABLE AS" 语句可以创建一个临时表,该表是基于查询结果创建的。临时表只在当前 SparkSession 中可见,并且在会话结束后会自动删除。
下面是一个示例:
```scala
val spark = SparkSession.builder()
.appName("CreateTemporaryTableExample")
.master("local")
.getOrCreate()
val data = Seq(
("Alice", 25),
("Bob", 30),
("Carol", 35)
)
val df = spark.createDataFrame(data).toDF("name", "age")
df.createOrReplaceTempView("people")
val result = spark.sql("SELECT * FROM people")
result.show()
```
在上面的示例中,我们首先创建了一个 SparkSession。然后,我们使用一个包含姓名和年龄的数据集创建了一个 DataFrame。接下来,我们使用 `createOrReplaceTempView` 方法将 DataFrame 注册为一个临时表,表名为 "people"。最后,我们使用 `spark.sql` 方法执行 SQL 查询并打印结果。
注意,临时表只在当前 SparkSession 中可见,如果你创建多个 SparkSession,它们之间的临时表是不可见的。
阅读全文