avg_by_key = rdd1.mapValues(lambda v: (v, 1)).reduceByKey(lambda a, b: (a[0
    ] + b[0], a[1] + b[1])).mapValues(lambda v: v[0] / v[1]).collectAsMap()
Вычисление средних значений для каждого KEY в парном (K, V) RDD в Spark с Python