99999久久久久久亚洲,欧美人与禽猛交狂配,高清日韩av在线影院,一个人在线高清免费观看,啦啦啦在线视频免费观看www

熱線電話：13121318867

登錄
2019-01-31 閱讀量: 773
RDD轉(zhuǎn)Dataset？

RDD如何轉(zhuǎn)Dataset？

答：

定義每一行的類型（case class）時，需要給出字段名和類型，后面只要往case class里面添加值即可

import spark.implicits._
case class Coltest(col1:String,col2:Int)extends Serializable //定義字段名和類型

val testDS = rdd.map {line=>
 Coltest(line._1,line._2)
 }.toDS

0.0000
1
關(guān)注作者
收藏
評論(0)

發(fā)表評論

暫無數(shù)據(jù)
推薦帖子