1 个回答
在spark sql中创建临时试图之后就可以进行查询了,创建临时试图的核心代码是:
示例如下:
$dataframe.createTempView(${tempview_name})
示例如下:
var user = Seq(UserPoJo("张三", 15, "男"),UserPoJo("李四", 16, "女"))
import session.implicits._
val users = user.toDF()
users.createTempView("user")
session.sql("select * from user limit 1").show()
发布于:2年前 (2022-12-13) IP属地:四川省
我来回答
您需要 登录 后回答此问题!