DataFrame注册成一张表格,如果通过CreateTempView这种方式来创建,那么该表格Session有效,如果通过CreateGlobalTempView来创建,那么该表格跨Session有效,但是SQL语句访问该表格的时候需要加上前缀global_temp
dataframe 转换为临时表,执行sparksql
val df = spark.read.json(Path)
df.show()
//将dataframe 注册成为一张临时表 df.createOrReplaceTempView("persons") spark.sql("select * from persons where age > 20 ").show()