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)


暂无数据
推荐帖子
0条评论
1条评论
0条评论