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