问Scala RDD[(String，String)]到RDD[String]
EN

Stack Overflow用户

提问于 2021-08-13 12:44:38

回答 1查看 35关注 0票数 0

我们正在以RDD(String，String)的形式读取UTF_8中的一个文件，需要帮助将其转换为RDDString。

val textRdd = sparkSession.sparkContext.binaryFiles(filePath,12)
     .mapValues(content => new String(content.toArray(), StandardCharsets.UTF_8))

发布于 2021-08-13 13:06:12

你只需要从元组中提取值，即(string，string)。

val outRDD = textRdd.map(t=>t._2) // To get first value use t._1

票数 1

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/68772559

复制

相似问题

问Scala RDD[(String，String)]到RDD[String]EN