rdd3 = rdd1.zip(rdd2).map(lambda a_b_c_d_e_f_g: (a_b_c_d_e_f_g[0][0], a_b_c_d_e_f_g[1][1]))
How to add columns of 2 RDDs to from a single RDD and then do aggregation of rows based on date data in PySpark