scala - 如何使用 Scala 在 Spark 核心中将 [(String, String)] 转换为 [String, String]

Question

如何使用 Scala 在 Spark 核心中转换 org.apache.spark.rdd.RDD[(String, String)] = org.apache.spark.rdd.RDD[String, String]

输入
(2020-01-19,错误)
(2020-01-19,信息)

输出
2020-01-19,错误
2020-01-19,信息

标签： scalaapache-spark

Answer 1

如何使用 Scala 在 Spark 核心中转换 org.apache.spark.rdd.RDD[(String, String)] = org.apache.spark.rdd.RDD[String, String]

您不能转换为org.apache.spark.rdd.RDD[String, String]，因为从的文档中org.apache.spark.rdd.RDD[T]可以清楚地看到 ，它只需要一个类型参数，而不是两个。你不能转换成不存在的东西。