zdd2 = rdd2.zipWithIndex().map(lambda v_k: (v_k[1], v_k[0]))
print(zdd1.join(zdd2).collect())
How to add columns of 2 RDDs to from a single RDD and then do aggregation of rows based on date data in PySpark