如何解决如何将案例类RDD转换为RDD[String]?
我有一个模式 rdd。如果我打印那个 RDD,我会得到类似的输出 caseclass_name(col a,col b,col c) caseclass_name(col d,col e,col f) ..... ..... 我需要简单地显示为(前面没有案例类名) col a,col c col d,col f
我怎样才能得到这个?请帮忙
解决方法
最简单的解决方案是覆盖案例类中的 toString
方法
case class iclass(Id1:Int,Id2:Int,SaleDate:String,Code:String) {
override def toString(): String = {
s"$Id1,$Id2,$SaleDate,$Code"
}
}
如果你有一个 RDD[iclass]
并且想把它转换成一个 RDD[String]
,你可以像 insureRDD1.map(_.toString)
一样映射它
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。