2016-09-20 80 views
0

我有两个RDD。在scala中结合了两个RDDs spark

RDD1集=(字符串,整数)

(a, 10) 
(b, 15) 
(c, 20) 
(d, 20) 
(e, 13) 

RDD2 =(字符串,字符串)

(1, a) 
(2, b) 
(3, e) 

当一些RDD2的价值观与RDD1集的钥匙一样,我怎么能合并他们像下面?可能吗?

(1, 10) 
(2, 15) 
(3, 13) 

回答

1

尝试:

rdd1.join(rdd2.map(_.swap)).values 
+0

它不工作。它说'无法解析符号连接'..你知道为什么吗? – tobby

+0

可能'rdd1'不是RDD。 – 2016-09-20 22:30:46

+0

哦,是的!我认为这不是RDD,但具有与上述相同的格式。那么你有什么其他的建议来合并它们吗? – tobby