rdd2 = sc.parallelize(range(5))
zdd1 = rdd1.zipWithIndex().map(lambda v_k: (v_k[1], v_k[0]))
zdd2 = rdd2.zipWithIndex().map(lambda v_k1: (v_k1[1], v_k1[0]))
print(zdd1.join(zdd2).collect())
Как добавить столбцы из 2 RDD из одного RDD, а затем выполнить агрегацию строк на основе данных даты в PySpark