您当前的位置: 首页 >  ar

宝哥大数据

暂无认证

  • 0浏览

    0关注

    1029博文

    0收益

  • 0浏览

    0点赞

    0打赏

    0留言

私信
关注
热门博文

Spark: scala.MatchError (of class org.apache.spark.sql.catalyst.expressions.GenericRowWithSchema

宝哥大数据 发布时间:2022-10-15 08:57:10 ,浏览量:0

在dataframe转为rdd


// 造源数据
val data = List( ("Jen","male",18))  
val df = spark.createDataFrame(data) 

import org.apache.spark.sql.Row
// dataframe转为rdd
val result = df.rdd.map{case Row(name: String, age: Integer) => (name, age)}

result.collect()

报错

Caused by: scala.MatchError: [Jen,male,18] (of class org.apache.spark.sql.catalyst.expressions.GenericRowWithSchema)

问题原因: 字段数量不一致,导致转化类型错误 在这里插入图片描述

改正: 在这里插入图片描述

关注
打赏
1587549273
查看更多评论
立即登录/注册

微信扫码登录

0.0406s