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)
我有兩個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)
嘗試:
rdd1.join(rdd2.map(_.swap)).values
它不工作。它說'無法解析符號連接'..你知道爲什麼嗎? – tobby
可能'rdd1'不是RDD。 – 2016-09-20 22:30:46
哦,是的!我認爲這不是RDD,但具有與上述相同的格式。那麼你有什麼其他的建議來合併它們嗎? – tobby