Hi Everyone Is there any difference in performance btw the following two joins?
val r1: RDD[(String, String]) = ??? val r2: RDD[(String, String]) = ??? val partNum = 80 val partitioner = new HashPartitioner(partNum) // Join 1 val res1 = r1.partitionBy(partitioner).join(r2.partitionBy(partitioner)) // Join 2 val res2 = r1.join(r2, partNum)
