Я хочу выровнять org.apache.spark.rdd.RDD [(Any, scala.collection.immutable.Iterable [String])] в строку в Scala

Question

Пример

(168,20874, Список (, 33895, 2711))

до 168,20874 |, 33895, 2711

В основном конвертировать RDD [(Any, scala.collection.immutable.Iterable [String])] в строку.

Спасибо

Answer 1

Может использоваться метод «map» с предопределенным форматером:

val rdd = sparkContext.parallelize(List((168, 20874, List(33895, 2711))))
val result = rdd.map { case (a, b, c) => s"$a,$b| ,${c.mkString(",")}" }
result.foreach(println)

Вывод:

168,20874| ,33895,2711