Spark:JavaRDD<Tuple2>到 JavaPairRDD<> [英] Spark: JavaRDD<Tuple2> to JavaPairRDD<>

查看:25
本文介绍了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&lt;Tuple2&gt;到 JavaPairRDD&lt;&gt;的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!

查看全文
相关文章
登录 关闭
扫码关注1秒登录
发送“验证码”获取 | 15天全站免登陆