Spark:JavaRDD<Tuple2>到 JavaPairRDD<&am
时间：2023-09-26
本文介绍了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<>的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持html5模板网！
相关文章
如何检测 32 位 int 上的整数溢出?How can I detect integer overflow on 32 bits int?(如何检测 32 位 int 上的整数溢出?)- return 语句之前的局部变量，这有关系吗?Local variables before return statements, does it matter?(return 语句之前的局部变量，这有关系吗?)
- 如何将整数转换为整数?How to convert Integer to int?(如何将整数转换为整数?)
- 如何在给定范围内创建一个随机打乱数字的 intHow do I create an int array with randomly shuffled numbers in a given range(如何在给定范围内创建一个随机打乱数字的 int 数组)
- java的行为不一致==Inconsistent behavior on java#39;s ==(java的行为不一致==)
- 为什么 Java 能够将 0xff000000 存储为 int?Why is Java able to store 0xff000000 as an int?(为什么 Java 能够将 0xff000000 存储为 int?)
最新文章
如何使用 SimpleDateFormat.parse() 将 Calendar.toString()How can I Convert Calendar.toString() into date using SimpleDateFormat.parse()?(如何使用 SimpleDateFormat.parse() 将 Calendar.toString() 转换为日期?)- JDK16 和 Mac OS 上的 Mockito - 无法初始化插件
- Mockito 模拟对象突然抛出 NPE
- 本机查询上的 Mockito NullPointerException
- 如何使用 Mockito 验证重载方法的调用次数?
- PowerMockito.doReturn 返回 null
- 通缉但不调用:Mockito PrintWriter
- Mockito 模拟 restTemplate.postForEntity
- 如何使用 String 和 class 作为参数为 EntityManger cr
- 模拟 ScheduledExecutorService 与“不要模拟你不拥有的
- 如何干净地测试使用 DomainClassConverter 检索参数的