老师，我写的强制类型转换那句代码报错，怎么处理呢？

Question

val file = spark.read.format(“csv”).option(“sep”,";").option(“header”,“true”).load(“house.csv”)
import spark.implicits._
//打乱顺序
val rand = new Random()
val data = file.select(“square”,“price”).map(
row => (row.getAsString.toDouble,row.getString(1).toDouble,rand.nextDouble()))
.toDF(“square”,“price”,“rand”).sort(“rand”)

Answer 1

Wotchin 2018-10-07 12:10:56

这个row是Row类型，是封装了数据的数据结构，取出数据的时候需要数据的索引，例如row.getAsString(0).toDouble

• 提问者 陈素素 #1

  我是这样转换了，可是还是报编码错误

• Wotchin 回复 提问者 陈素素 #2

  把异常写上来

• 提问者 陈素素 #3

  val data = file.select("square", "price").map(
          row => (row.getAs[String](0).toDouble , row.getString(1).toDouble)).toDF("square","price").show()
  就这句代码还是报错

点开查看后面7条评论