2016-09-20 83 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