如何将 case class RDD 转换为 RDD[String]？

Question

我有一个模式 rdd。如果我打印那个 RDD，我会得到类似的输出 caseclass_name（a 栏、b 栏、c 栏） caseclass_name(col d,col e,col f) ..... ..... 我需要简单地显示为（前面没有大小写 class 名称） col a, col b, col c col d, col e, col f

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

Answer 1

最简单的解决方案是根据您的情况重写 toString 方法 class

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)

如何将 case class RDD 转换为 RDD[String]？

How to convert case class RDD to RDD[String]?

scala

class

case

apache-spark

rdd