热线电话:13121318867

登录
2019-01-31 阅读量: 780
DataFrame转Dataset

DataFrame如何转Dataset?

答:方法如下在给出每一列的类型后,使用as方法,转成Dataset,这在数据类型是DataFrame又需要针对各个字段处理时极为方便

import spark.implicits._
case class Coltest(col1:String,col2:Int)extends Serializable //定义字段名和类型
val testDS = testDF.as[Coltest]

注:一定要加上 import spark.implicits._ 不然toDF、toDS无法使用

0.0000
1
关注作者
收藏
评论(0)

发表评论

暂无数据
推荐帖子