兩個 RDD 的行數相同。我正在尋找與 cbind() 等效的 R
似乎 join() 總是需要一個密鑰。
uj5u.com熱心網友回復:
最接近的是.zip方法。適當的后續.map使用。例如:
val rdd0 = sc.parallelize(Seq( (1, (2,3)), (2, (3,4)) ))
val rdd1 = sc.parallelize(Seq( (200,300), (300,400) ))
val zipRdd = (rdd0 zip rdd1).collect
回傳:
zipRdd: Array[((Int, (Int, Int)), (Int, Int))] = Array(((1,(2,3)),(200,300)), ((2,(3,4)),(300,400)))
實際上基于 k,v 需要相同的行數。
轉載請註明出處,本文鏈接:https://www.uj5u.com/ruanti/453078.html
