如何将 case RDD 转换为 RDD [String]?

严酷的普里亚德

我有一个模式rdd。如果我打印那个 RDD,我会得到像 caseclass_name(col a, col b,col c) caseclass_name(col d,col e, col f) ..... .... 我需要简单地显示为(前面没有case类名) col a, col b, col c col d, col e, col f

我怎样才能得到这个?请协助

卡尼尔

最简单的解决方案是覆盖toString案例类中方法

case class iclass(Id1:Int,Id2:Int,SaleDate:String,Code:String) {
  override def toString(): String = {
    s"$Id1,$Id2,$SaleDate,$Code"
  }
}

如果您有 anRDD[iclass]并想将其转换为 an RDD[String],则可以将其映射为insureRDD1.map(_.toString)

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章