Spark: JavaRDDlt;Tuple2gt; to JavaPairRDDlt;gt;(Spark:JavaRDDlt;Tuple2gt;到 JavaPairRDDlt;gt;)
问题描述
我有一个 JavaRDD<Tuple2<String, String>>
,需要将其转换为 JavaPairRDD<String, String>
.目前我通过简单地编写只返回输入元组的映射函数来做到这一点.但是不知道有没有更好的办法?
I have a JavaRDD<Tuple2<String, String>>
and need to transform it to JavaPairRDD<String, String>
. Currently I am doing it by simply writing map function that just returns the input tuple as is. But I wonder if there is a better way?
推荐答案
JavaPairRDD.fromJavaRDD(rdd) 是解决方案之一
JavaPairRDD.fromJavaRDD(rdd) is one of solutions
这篇关于Spark:JavaRDD<Tuple2>到 JavaPairRDD<>的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!
本文标题为:Spark:JavaRDD<Tuple2>到 JavaPairRDD<>


- C++ 和 Java 进程之间的共享内存 2022-01-01
- 将log4j 1.2配置转换为log4j 2配置 2022-01-01
- Safepoint+stats 日志,输出 JDK12 中没有 vmop 操作 2022-01-01
- Eclipse 插件更新错误日志在哪里? 2022-01-01
- Java包名称中单词分隔符的约定是什么? 2022-01-01
- Jersey REST 客户端:发布多部分数据 2022-01-01
- 从 finally 块返回时 Java 的奇怪行为 2022-01-01
- value & 是什么意思?0xff 在 Java 中做什么? 2022-01-01
- Spring Boot连接到使用仲裁器运行的MongoDB副本集 2022-01-01
- 如何使用WebFilter实现授权头检查 2022-01-01