lines = sc.parallelize(['id1,pd1,t1,5.0', 'id2,pd2,t2,6.0',
    'id1,pd1,t2,7.5', 'id1,pd1,t3,8.1'])
rdd = lines.map(lambda x: x.split(',')).map(lambda x: (x[0] + ', ' + x[1],
    x[3])).reduceByKey(lambda a, b: a + ', ' + b)
Как сгруппировать по нескольким ключам в spark?