如何将df_sales的SQL查询结果转为TempView以创建新SQL查询

你可以通过Spark DataFrame的内置方法直接创建临时视图，常用方式有两种：

1. 使用createOrReplaceTempView（推荐） #

该方法会创建指定名称的临时视图，若同名视图已存在则自动替换，避免重复视图导致的异常。

代码示例：

# 将df_sales转换为名为sales_view的临时视图
df_sales.createOrReplaceTempView("sales_view")

之后即可基于该视图编写新SQL查询：

-- 示例：按日期统计销售总量
SELECT TRANS_DT, SUM(SALES_QTY) AS total_sales
FROM sales_view
GROUP BY TRANS_DT;

2. 使用createTempView #

该方法仅在目标视图不存在时创建，若已有同名视图，执行时会抛出异常。

代码示例：

df_sales.createTempView("sales_view")

额外说明 #

• 以上两种临时视图的生命周期与当前SparkSession绑定，Session关闭后视图会自动销毁。
• 若需跨多个SparkSession访问视图，可使用createGlobalTempView，访问时需添加global_temp.前缀，例如SELECT * FROM global_temp.sales_view;

内容的提问来源于stack exchange，提问作者Murat