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<>


基础教程推荐
- RabbitMQ:消息保持“未确认"; 2022-01-01
- Struts2 URL 无法访问 2022-01-01
- 使用堆栈算法进行括号/括号匹配 2022-01-01
- 存储 20 位数字的数据类型 2022-01-01
- REST Web 服务返回 415 - 不支持的媒体类型 2022-01-01
- 无法复制:“比较方法违反了它的一般约定!" 2022-01-01
- 修改 void 函数的输入参数,然后读取 2022-01-01
- 问题http://apache.org/xml/features/xinclude测试日志4j 2 2022-01-01
- Spring AOP错误无法懒惰地为此建议构建thisJoinPoin 2022-09-13
- 如何对 Java Hashmap 中的值求和 2022-01-01