代码之家 › 专栏 › 技术社区 › yanachen

两个rdd连接的结果是什么?

rdd pyspark

1

yanachen · 技术社区 · 9 年前

(h5id,[query]) (h5id, [0:id, 1:query, 2:q0, 3:q1, 4:q2, 5:q3, 6:s0, 7:s1, 8:s2, 9:s3] ). 结果是什么 clickJoin = clickRdd.join(revealRdd) ,我想连接键是h5id。

1 回复 | 直到 9 年前

1

Suresh 9 年前

连接的RDD将以元组中的RDD值和hi5id作为键。

clickJoin.take(1)
[(hi5id,([query],[0:id, 1:query, 2:q0, 3:q1, 4:q2, 5:q3, 6:s0, 7:s1, 8:s2, 9:s3]))]