Spark: JavaRDDlt;Tuple2gt; to JavaPairRDDlt;gt;(Spark:JavaRDDlt;Tuple2gt;到 JavaPairRDDlt;gt;)
本文介绍了Spark:JavaRDD<Tuple2>到 JavaPairRDD<>的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述
我有一个 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<>
基础教程推荐
猜你喜欢
- 设置 bean 时出现 Nullpointerexception 2022-01-01
- FirebaseListAdapter 不推送聊天应用程序的单个项目 - Firebase-Ui 3.1 2022-01-01
- 在 Libgdx 中处理屏幕的正确方法 2022-01-01
- Java:带有char数组的println给出乱码 2022-01-01
- 降序排序:Java Map 2022-01-01
- 减少 JVM 暂停时间 >1 秒使用 UseConcMarkSweepGC 2022-01-01
- “未找到匹配项"使用 matcher 的 group 方法时 2022-01-01
- 无法使用修饰符“public final"访问 java.util.Ha 2022-01-01
- Java Keytool 导入证书后出错，"keytool error: java.io.FileNotFoundException &拒绝访问" 2022-01-01
- 如何使用 Java 创建 X509 证书? 2022-01-01
